Interface ForEachStream

Yields the observer's own record-saved events plus fixed-point and closed.

interface ForEachStream {
    "[asyncIterator]"(): AsyncIterator<OpenEvent, any, any>;
    close(): Promise<void>;
    nextEvent(): Promise<OpenEvent>;
}

Hierarchy

AsyncIterable<OpenEvent>
- ForEachStream

Index

Methods

[asyncIterator] close nextEvent

Methods

[asyncIterator]

"[asyncIterator]"(): AsyncIterator<OpenEvent, any, any>

Returns AsyncIterator<OpenEvent, any, any>

Inherited from AsyncIterable.[asyncIterator]

close

close(): Promise<void>

Returns Promise<void>

nextEvent

nextEvent(): Promise<OpenEvent>

Returns Promise<OpenEvent>