SubFlow

org.apache.pekko.stream.javadsl.SubFlow$
See theSubFlow companion class
object SubFlow

Attributes

Companion
class
Source
SubFlow.scala
Graph
Supertypes
class Object
trait Matchable
class Any
Self type
SubFlow.type

Members list

Value members

Concrete methods

def upcast[In, SuperOut, Out <: SuperOut, M](flow: SubFlow[In, Out, M]): SubFlow[In, SuperOut, M]

Upcast a stream of elements to a stream of supertypes of that element. Useful in combination with fan-in operators where you do not want to pay the cost of casting each element in a map.

Upcast a stream of elements to a stream of supertypes of that element. Useful in combination with fan-in operators where you do not want to pay the cost of casting each element in a map.

Type parameters

SuperOut

a supertype to the type of element flowing out of the flow

Attributes

Returns

A flow that accepts In and outputs elements of the super type

Source
SubFlow.scala