import { AsyncIterableLike } from "../async-like";
import { Cancellable } from "./cancellable";
export type TransientAsyncIteratorSourceOnThrowFn<T> = (error: unknown) => void | Promise<void> | IteratorResult<T> | Promise<IteratorResult<T>>;
export type TransientAsyncIteratorSourceFn<T> = (() => Promise<T>) | (() => T);
export declare function source<T>(source?: AsyncIterableLike<T> | TransientAsyncIteratorSourceFn<T>, cancellable?: Cancellable): TransientAsyncIteratorSource<T>;
export declare class TransientAsyncIteratorSource<T = any> implements AsyncIterable<T> {
    private source?;
    private sourceCancellable?;
    private onThrow?;
    private sourceIterator?;
    private deferred;
    private isDone;
    private errorValue;
    private pullPromise;
    private values;
    private nextPointer;
    private pointer;
    constructor(source?: AsyncIterableLike<T>, sourceCancellable?: Cancellable, onThrow?: TransientAsyncIteratorSourceOnThrowFn<T>);
    static from<T>(source?: AsyncIterableLike<T> | TransientAsyncIteratorSourceFn<T>, cancellable?: Cancellable): TransientAsyncIteratorSource<T>;
    get error(): unknown;
    get open(): boolean;
    get hasSource(): boolean;
    /**
     * @param value
     * @returns {boolean} false if the value won't be processed
     */
    push(value: T): boolean;
    /**
     * @returns {boolean} false if the pushable is not open
     */
    close(): boolean;
    /**
     * @param error
     * @returns {boolean} false if the pushable is not open
     */
    throw(error?: unknown): boolean;
    setSource(source?: AsyncIterableLike<T>, sourceCancellable?: Cancellable): Promise<void>;
    private pull;
    private waitForNext;
    private invokeDeferred;
    [Symbol.asyncIterator](): {
        next: () => Promise<IteratorReturnResult<any> | IteratorYieldResult<T>>;
        return: () => Promise<IteratorResult<T>>;
        throw: (error?: unknown) => Promise<IteratorResult<T>>;
    };
}
export declare function isTransientAsyncIteratorSource(value: unknown): value is TransientAsyncIteratorSource<any>;