import { IQueueWorkload } from './IQueueWorkload'; import { AsyncWorkerQueue } from './AsyncWorkerQueue'; export interface IQueueProcessor { do(workLoad: T, queue?: AsyncWorkerQueue): Promise; onEmpty?(): Promise; onNext?(): void; }