for await, .on(), .filter(),
.map(), .take(), and Symbol.asyncDispose.
Only one consumer is allowed per stream instance. Calling .on() or
iterating a stream that is already being consumed throws an error.
Use .filter() / .map() / .take() to derive new streams before
consuming them.
Constructor
Parameters
AsyncIterable<T>
required
() => Promise<void>
Returns
TypedEventStream
Methods
asyncDispose
Returns
Promise<void>
asyncIterator
Returns
AsyncIterator<T>
close()
Returns
Promise<void>
filter()
Parameters
(event: T) => event
required
Returns
TypedEventStream
Parameters
(event: T) => boolean
required
Returns
TypedEventStream
map()
Parameters
(event: T) => U
required
Returns
TypedEventStream
on()
Parameters
(event: T) => void | Promise<void>
required
Returns
() => void
take()
Parameters
number
required
Returns
TypedEventStream