XStreamSemaphore<T> extension
- on
-
- Stream<
T>
- Stream<
Methods
-
parallelMap<
V> (Future< V> mapper(T t)) → Stream<V> -
Available on Stream<
Unlike asyncMap and semaphoreMap: the order of the output is not guaranteed. As soon as a Future is completed, it is yielded. Once all Futures are completed, the Stream is completed.T> , provided by the XStreamSemaphore extension -
semaphoreMap<
V> (int bufferSize, Future< V> mapper(T t)) → Stream<V> -
Available on Stream<
Unlike asyncMap: INPUT -> (await) MAPPER -> OUTPUTT> , provided by the XStreamSemaphore extension