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

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)

Methods inherited from class java.lang.Object

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

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.

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 class java.lang.Object

unmarkAllOutputs

public void unmarkAllOutputs()

unmarkCancelledOutputs

public void unmarkCancelledOutputs(boolean enabled)

unmarkOutput

public void unmarkOutput(int output)