statefulMapConcat

Transform each element into zero or more elements that are individually passed downstream.

Simple operators

Signature

def statefulMapConcat[T](f: () => Out => immutable.Iterable[T]): Repr[T]

Description

Transform each element into zero or more elements that are individually passed downstream. The difference to mapConcat is that the transformation function is created from a factory for every materialization of the flow.

emits when the mapping function returns an element or there are still remaining elements from the previously calculated collection

backpressures when downstream backpressures or there are still available elements from the previously calculated collection

completes when upstream completes and all remaining elements has been emitted

Found an error in this documentation? The source code for this page can be found here. Please feel free to edit and contribute a pull request.