export interface AbortOptions {
    signal?: AbortSignal;
}
export declare type Source<T> = AsyncIterable<T>;
export interface Sink<T> {
    (source: AsyncIterable<T>): Promise<void>;
}
export interface DuplexStream<T> {
    source: Source<T>;
    sink: Sink<T>;
}
//# sourceMappingURL=types.d.ts.map