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
    • Constructor Detail

      • KillSwitches

        public KillSwitches()
    • Method Detail

      • single

        public static <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 static <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)