Package akka.stream

Class KillSwitches$


  • public class KillSwitches$
    extends java.lang.Object
    Creates a new SharedKillSwitch with the given name that can be used to control the completion of multiple streams from the outside simultaneously.

    See Also:
    SharedKillSwitch
    • Field Detail

      • MODULE$

        public static final KillSwitches$ MODULE$
        Static reference to the singleton instance of this Scala object.
    • Constructor Detail

      • KillSwitches$

        public KillSwitches$()
    • Method Detail

      • single

        public <T> Graph<FlowShape<T,​T>,​UniqueKillSwitch> single()
        Creates a new Graph of FlowShape that materializes to an external switch that allows external completion of that unique materialization. Different materializations result in different, independent switches.

        For a Bidi version see KillSwitch#singleBidi

        Returns:
        (undocumented)
      • singleBidi

        public <T1,​T2> Graph<BidiShape<T1,​T1,​T2,​T2>,​UniqueKillSwitch> singleBidi()
        Creates a new Graph of FlowShape that materializes to an external switch that allows external completion of that unique materialization. Different materializations result in different, independent switches.

        For a Flow version see KillSwitch#single

        Returns:
        (undocumented)