Function createQueue

Returns {
    observable: Observable<Data>;
    destroy() => void;
    process<R>(data) => Promise<R>;
}

• observable: Observable<Data>

• destroy:function

  • destroy(): void

  • Returns void

• process:function

  • process<R>(data): Promise<R>

  • Type Parameters

    • R = any

    Parameters

    • data: D

    Returns Promise<R>