import * as O from "../../../Option"; import * as T from "../../Task"; import * as R from "../../XRef"; export declare class BufferedPull { readonly upstream: T.Task, ReadonlyArray>; readonly done: R.Ref; readonly cursor: R.Ref<[ReadonlyArray, number]>; constructor( upstream: T.Task, ReadonlyArray>, done: R.Ref, cursor: R.Ref<[ReadonlyArray, number]> ); } export declare const ifNotDone: ( fa: T.Task, A1> ) => (self: BufferedPull) => T.Task, A1>; export declare const update: (self: BufferedPull) => T.Task, void>; export declare const pullElement: (self: BufferedPull) => T.Task, A>; export declare const pullArray: (self: BufferedPull) => T.Task, readonly A[]>; export declare const make: ( pull: T.Task, readonly A[]> ) => T.Task>; //# sourceMappingURL=BufferedPull.d.ts.map