Package akka.stream.scaladsl

Class Partition$

  • public class Partition$
extends java.lang.Object

    • Field Summary

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

    • Constructor Summary

      Constructors 
      Constructor Description
      Partition$()  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      <T> Partition<T> apply​(int outputPorts, scala.Function1<T,​java.lang.Object> partitioner)
      Create a new Partition operator with the specified input type.

      • Methods inherited from class java.lang.Object

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

    • Field Detail

      • MODULE$

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

    • Constructor Detail

      • Partition$

        public Partition$()

    • Method Detail

      • apply

        public <T> Partition<T> apply​(int outputPorts,
                              scala.Function1<T,​java.lang.Object> partitioner)
        Create a new Partition operator with the specified input type. This method sets eagerCancel to false. To specify a different value for the eagerCancel parameter, then instantiate Partition using the constructor.

        If eagerCancel is true, partition cancels upstream if any of its downstreams cancel, if false, when all have cancelled.

        Parameters:
        outputPorts - number of output ports
        partitioner - function deciding which output each element will be targeted