AsyncExpand<T> extension
Alternatives to asyncExpand.
The built in asyncExpand will not overlap the inner streams and every event will be sent to the callback individually.
- concurrentAsyncExpand allow overlap and merges inner streams without ordering guarantees.
- on
-
- Stream<
T>
- Stream<
Methods
-
concurrentAsyncExpand<
S> (Stream< S> convert(T)) → Stream<S> -
Like asyncExpand but the
convertcallback may be called for an element before the Stream emitted by the previous element has closed.