Package akka.stream

Class KillSwitches.KillableGraphStageLogic

    • Constructor Detail

      • KillableGraphStageLogic

        public KillableGraphStageLogic​(scala.concurrent.Future<Done> terminationSignal,
                                       Shape _shape)
    • Method Detail

      • preStart

        public void preStart()
        Description copied from class: GraphStageLogic
        Invoked before any external events are processed, at the startup of the operator.
        Overrides:
        preStart in class GraphStageLogic
      • terminationSignal

        public scala.concurrent.Future<Done> terminationSignal()