Creates an AsyncIterableIterator, that also exposes
a push(...) method that can be used to push values into it (for example based on events).
a done() method that can be used to indicate that no more values will follow.
The optional bufferSize parameter defines how large the buffer is that will hold the
messages until they are pulled by a next() call. The oldest messages will be
dropped if no one is consuming the iterator fast enough.
If no bufferSize is specified, the buffer will keep growing indefinitely.
Creates an AsyncIterableIterator, that also exposes
The optional bufferSize parameter defines how large the buffer is that will hold the messages until they are pulled by a next() call. The oldest messages will be dropped if no one is consuming the iterator fast enough.
If no bufferSize is specified, the buffer will keep growing indefinitely.
Returns