Package org.apache.pekko.stream.javadsl

Class SubFlow$

java.lang.Object
org.apache.pekko.stream.javadsl.SubFlow$
public class SubFlow$ extends Object

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final SubFlow$
    MODULE$
    Static reference to the singleton instance of this Scala object.

  • Constructor Summary

    Constructors
    Constructor
    Description
    SubFlow$()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    <In, SuperOut, Out extends SuperOut, M>
    SubFlow<In,SuperOut,M>
    upcast(SubFlow<In,Out,M> flow)
    Upcast a stream of elements to a stream of supertypes of that element.

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Field Details

    • MODULE$

      public static final SubFlow$ MODULE$
      Static reference to the singleton instance of this Scala object.

  • Constructor Details

    • SubFlow$

      public SubFlow$()

  • Method Details

    • upcast

      public <In, SuperOut, Out extends SuperOut, M> SubFlow<In,SuperOut,M> upcast(SubFlow<In,Out,M> flow)
      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.

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