21 lines
652 B
TypeScript
21 lines
652 B
TypeScript
import { $$asyncIterator } from 'iterall';
|
|
import { PubSubEngine } from './pubsub-engine';
|
|
export declare class PubSubAsyncIterator<T> implements AsyncIterator<T> {
|
|
private pullQueue;
|
|
private pushQueue;
|
|
private eventsArray;
|
|
private allSubscribed;
|
|
private running;
|
|
private pubsub;
|
|
constructor(pubsub: PubSubEngine, eventNames: string | string[]);
|
|
next(): Promise<IteratorResult<T>>;
|
|
return(): Promise<IteratorResult<T>>;
|
|
throw(error: any): Promise<never>;
|
|
[$$asyncIterator](): this;
|
|
private pushValue;
|
|
private pullValue;
|
|
private emptyQueue;
|
|
private subscribeAll;
|
|
private unsubscribeAll;
|
|
}
|