Class MergeHub.MergedSourceLogic

    • Constructor Detail

      • MergedSourceLogic

        public MergedSourceLogic​(SourceShape<T> _shape)
    • Method Detail

      • isShuttingDown

        public boolean isShuttingDown()
      • onPull

        public void onPull()
        Description copied from interface: OutHandler
        Called when the output port has received a pull, and therefore ready to emit an element, i.e. GraphStageLogic.push is now allowed to be called on this port.
        Specified by:
        onPull in interface OutHandler
      • postStop

        public void postStop()
        Description copied from class: GraphStageLogic
        Invoked after processing of external events stopped because the operator is about to stop or fail.
        Overrides:
        postStop in class GraphStageLogic