export type AsyncQueue<T> = {
    push: (value: T) => void;
    fail: (err: Error) => void;
    close: () => void;
    iterable: AsyncIterable<T>;
};
export declare function createAsyncQueue<T>(options?: {
    onCancel?: () => void;
}): AsyncQueue<T>;