Package akka.stream.impl
Class FanOut.OutputBunch
- java.lang.Object
-
- akka.stream.impl.FanOut.OutputBunch
-
- Enclosing class:
- FanOut
public static class FanOut.OutputBunch extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description OutputBunch(int outputCount, ActorRef impl, Pump pump)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description 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.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.void
cancel(java.lang.Throwable e)
void
complete()
void
complete(int output)
java.lang.Object
demandAvailableFor(int id)
java.lang.Object
demandOrCancelAvailableFor(int id)
void
enqueue(int id, java.lang.Object elem)
void
enqueueAndPrefer(java.lang.Object elem, int preferred)
void
enqueueAndYield(java.lang.Object elem)
void
enqueueMarked(java.lang.Object elem)
void
error(int output, java.lang.Throwable e)
int
idToEnqueue()
int
idToEnqueueAndYield()
boolean
isCancelled(int output)
boolean
isCompleted(int output)
boolean
isErrored(int output)
boolean
isPending(int output)
void
markAllOutputs()
void
markOutput(int output)
void
onCancel(int output)
SubReceive
subreceive()
java.lang.String
toString()
void
unmarkAllOutputs()
void
unmarkCancelledOutputs(boolean enabled)
void
unmarkOutput(int output)
-
-
-
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.- Returns:
- (undocumented)
-
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.- Returns:
- (undocumented)
-
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)
-
subreceive
public SubReceive subreceive()
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
unmarkAllOutputs
public void unmarkAllOutputs()
-
unmarkCancelledOutputs
public void unmarkCancelledOutputs(boolean enabled)
-
unmarkOutput
public void unmarkOutput(int output)
-
-