_build
- Source
- _build.scala
Def
Partial map
Partial map
Creates a new Stream.Flow by applying a partial function to all elements of current Stream.Flow on which the function is defined.
- Source
- _build.scala
Reverse filter
Reverse filter
Disallows Stream.Flow elements satisfying the given function
- Source
- _build.scala
Flat map
Flat map
Creates a new Stream.Flow by applying given function to all elements of current Stream.Flow and concatenating the results
- Source
- _build.scala
Simple map
Simple map
Creates a new Stream.Flow where each element is a result of applying given function to current Stream.Flow elements
- Source
- _build.scala
Optional map
Optional map
Creates a new Stream.Flow where each element is a result of applying given function to current Stream.Flow elements
It the function returns void option, the elements are dropped
- Source
- _build.scala
Inspect
Inspect
The given function will be run for every passing stream flow element.
- Source
- _build.scala
Indexed peek
Indexed peek
The given function will be executed for every passing element and its index.
- Source
- _build.scala
Convert to stream
Convert to stream
Wraps Stream.Flow into regular stream.
If Stream.Flow is parallel, then this convertion can be very costly, and it is always prefferable to consume Stream.Flow without going back to Stream
- Source
- _build.scala