Function isTaskFlushedError

packages/node-core/src/utils/queues/autoQueue.ts:16–18

(e: any)

}

export function isTaskFlushedError(e: any): e is TaskFlushedError {
  return (e as TaskFlushedError)?.name === 'TaskFlushedError';
}

export type Task<T> = () => Promise<T> | T;