Alternatives to asyncMap.
The built in asyncMap will not overlap execution of the passed callback, and every event will be sent to the callback individually.
asyncMapBufferprevents the callback from overlapping execution and collects events while it is executing to process in batches.
asyncMapSampleprevents overlapping execution and discards events while it is executing.
concurrentAsyncMapallows overlap and removes ordering guarantees.
S>( Future< S>convert(List< T>)) → Stream< S>
asyncMapbut events are buffered until previous events have been processed by
S>( Future< S>convert(T)) → Stream< S>
asyncMapbut events are discarded while work is happening in
S>( FutureOr< S>convert(T)) → Stream< S>
convertcallback may be called for an element before processing for the previous element is finished. [...]