Package akka.stream.stage

Class GraphStageLogic.SubSourceOutlet<T>

  • Enclosing class:
    GraphStageLogic
    public class GraphStageLogic.SubSourceOutlet<T>
extends java.lang.Object

    • Constructor Summary

      Constructors 
      Constructor Description
      SubSourceOutlet​(java.lang.String name)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void complete()
      Complete this output port.
      void fail​(java.lang.Throwable ex)
      Fail this output port.
      boolean isAvailable()
      Returns true if this output port can be pushed.
      boolean isClosed()
      Returns true if this output port is closed, but caution THIS WORKS DIFFERENTLY THAN THE NORMAL isClosed(out).
      void push​(T elem)
      Push to this output port.
      void setHandler​(OutHandler handler)
      Set OutHandler for this dynamic output port; this needs to be done before the first substream callback can arrive.
      Graph<SourceShape<T>,​NotUsed> source()
      Get the Source for this dynamic output port.
      void timeout​(scala.concurrent.duration.FiniteDuration d)
      Set the source into timed-out mode if it has not yet been materialized.
      java.lang.String toString()  

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • SubSourceOutlet

        public SubSourceOutlet​(java.lang.String name)

    • Method Detail

      • complete

        public void complete()
        Complete this output port.

      • fail

        public void fail​(java.lang.Throwable ex)
        Fail this output port.
        Parameters:
        ex - (undocumented)

      • isAvailable

        public boolean isAvailable()
        Returns true if this output port can be pushed.
        Returns:
        (undocumented)

      • isClosed

        public boolean isClosed()
        Returns true if this output port is closed, but caution THIS WORKS DIFFERENTLY THAN THE NORMAL isClosed(out). Due to possibly asynchronous shutdown it may not return true immediately after complete() or fail() have returned.
        Returns:
        (undocumented)

      • push

        public void push​(T elem)
        Push to this output port.
        Parameters:
        elem - (undocumented)

      • setHandler

        public void setHandler​(OutHandler handler)
        Set OutHandler for this dynamic output port; this needs to be done before the first substream callback can arrive.
        Parameters:
        handler - (undocumented)

      • source

        public Graph<SourceShape<T>,​NotUsed> source()
        Get the Source for this dynamic output port.
        Returns:
        (undocumented)

      • timeout

        public void timeout​(scala.concurrent.duration.FiniteDuration d)
        Set the source into timed-out mode if it has not yet been materialized.
        Parameters:
        d - (undocumented)

      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object