import type { Option } from "../../../Option";
import * as T from "../../Task";
import * as XP from "../../XPromise";
import * as XR from "../../XRef";
declare type State<A> = Empty | Full<A>;
declare class Empty {
   readonly notifyConsumer: XP.XPromise<never, void>;
   readonly _tag = "Empty";
   constructor(notifyConsumer: XP.XPromise<never, void>);
}
declare class Full<A> {
   readonly a: A;
   readonly notifyProducer: XP.XPromise<never, void>;
   readonly _tag = "Full";
   constructor(a: A, notifyProducer: XP.XPromise<never, void>);
}
/**
 * A synchronous queue-like abstraction that allows a producer to offer
 * an element and wait for it to be taken, and allows a consumer to wait
 * for an element to be available.
 */
declare class Handoff<A> {
   readonly ref: XR.Ref<State<A>>;
   readonly _tag = "Handoff";
   constructor(ref: XR.Ref<State<A>>);
}
export declare function make<A>(): T.IO<Handoff<A>>;
export declare function offer<A>(a: A): (h: Handoff<A>) => T.IO<void>;
export declare function take<A>(h: Handoff<A>): T.IO<A>;
export declare function poll<A>(h: Handoff<A>): T.IO<Option<A>>;
export {};
//# sourceMappingURL=Handoff.d.ts.map