Class FanOut.OutputBunch

  • Enclosing class:

    public static class FanOut.OutputBunch
    extends java.lang.Object
    • Constructor Detail

      • OutputBunch

        public OutputBunch​(int outputCount,
                           ActorRef impl,
                           Pump pump)
    • Method Detail

      • AllOfMarkedOutputs

        public java.lang.Object AllOfMarkedOutputs()
        Will only transfer an element when all marked outputs have demand, and will complete as soon as any of the marked outputs have canceled.
      • AnyOfMarkedOutputs

        public java.lang.Object AnyOfMarkedOutputs()
        Will transfer an element when any of the marked outputs have demand, and will complete when all of the marked outputs have canceled.
      • cancel

        public void cancel​(java.lang.Throwable e)
      • complete

        public void complete()
      • complete

        public void complete​(int output)
      • demandAvailableFor

        public java.lang.Object demandAvailableFor​(int id)
      • demandOrCancelAvailableFor

        public java.lang.Object demandOrCancelAvailableFor​(int id)
      • enqueue

        public void enqueue​(int id,
                            java.lang.Object elem)
      • enqueueAndPrefer

        public void enqueueAndPrefer​(java.lang.Object elem,
                                     int preferred)
      • enqueueAndYield

        public void enqueueAndYield​(java.lang.Object elem)
      • enqueueMarked

        public void enqueueMarked​(java.lang.Object elem)
      • error

        public void error​(int output,
                          java.lang.Throwable e)
      • idToEnqueue

        public int idToEnqueue()
      • idToEnqueueAndYield

        public int idToEnqueueAndYield()
      • isCancelled

        public boolean isCancelled​(int output)
      • isCompleted

        public boolean isCompleted​(int output)
      • isErrored

        public boolean isErrored​(int output)
      • isPending

        public boolean isPending​(int output)
      • markAllOutputs

        public void markAllOutputs()
      • markOutput

        public void markOutput​(int output)
      • onCancel

        public void onCancel​(int output)
      • toString

        public java.lang.String toString()
        toString in class java.lang.Object
      • unmarkAllOutputs

        public void unmarkAllOutputs()
      • unmarkCancelledOutputs

        public void unmarkCancelledOutputs​(boolean enabled)
      • unmarkOutput

        public void unmarkOutput​(int output)