import { PubSub } from "./pubsub";
/**
 * T 为 { value: T, done: false }
 */
export declare class PubSubAsyncIterator<T> implements AsyncIterator<T> {
    private running;
    private pubsub;
    private triggerNames;
    private allSubscribed;
    private pullQueue;
    private pushQueue;
    constructor(pubsub: PubSub, triggerNames: string | string[]);
    [Symbol.asyncIterator](): this;
    next(): Promise<IteratorResult<T>>;
    return(): Promise<IteratorResult<T>>;
    throw(error: Error): Promise<never>;
    emptyQueue(): Promise<void>;
}