Package akka.stream.scaladsl

Class Balance$

  • public class Balance$
extends java.lang.Object
    Create a new Balance with the specified number of output ports. This method sets eagerCancel to false. To specify a different value for the eagerCancel parameter, then instantiate Balance using the constructor.

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

    param: outputPorts number of output ports param: waitForAllDownstreams if you use waitForAllDownstreams = true it will not start emitting elements to downstream outputs until all of them have requested at least one element, default value is false

    • Field Summary

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

    • Constructor Summary

      Constructors 
      Constructor Description
      Balance$()  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      <T> Balance<T> apply​(int outputPorts, boolean waitForAllDownstreams)  
      <T> boolean apply$default$2()  

      • Methods inherited from class java.lang.Object

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

    • Field Detail

      • MODULE$

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

    • Constructor Detail

      • Balance$

        public Balance$()

    • Method Detail

      • apply

        public <T> Balance<T> apply​(int outputPorts,
                            boolean waitForAllDownstreams)

      • apply$default$2

        public <T> boolean apply$default$2()