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>

Methods

concurrentAsyncExpand<S>(Stream<S> convert(T)) → Stream<S>

Available on Stream<T>, provided by the AsyncExpand extension

Like asyncExpand but the convert callback may be called for an element before the Stream emitted by the previous element has closed.