rsocket-js
rsocket-js copied to clipboard
adds support for flowable to async iterable conversion
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]