rsocket-js icon indicating copy to clipboard operation
rsocket-js copied to clipboard

adds support for flowable to async iterable conversion

Open OlegDokuka opened this issue 5 years ago • 0 comments

This PR introduces integration with AsyncIterator which allows asynchronously iterate over a data stream using a common for-loop statement.

For example:

const asyncIterable = rsocket
  .requestChannel(...)
  .toAsyncIterable(4);

for await (const element of asyncIterable) {
  ...
}

Signed-off-by: Oleh Dokuka [email protected]

OlegDokuka avatar Oct 31 '20 21:10 OlegDokuka