Function createQueue

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