Skip to content

Conversation

OlegDokuka
Copy link
Member

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 OlegDokuka added the enhancement Suggests, requests, or implements a feature or enhancement label Oct 31, 2020
@OlegDokuka OlegDokuka force-pushed the enhancement/flowable-to-async-iterable branch 2 times, most recently from 8496348 to 24d78e7 Compare November 1, 2020 07:45
@OlegDokuka OlegDokuka force-pushed the enhancement/flowable-to-async-iterable branch from 24d78e7 to 013f048 Compare November 1, 2020 07:46
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
enhancement Suggests, requests, or implements a feature or enhancement
Projects
None yet
Development

Successfully merging this pull request may close these issues.

1 participant