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 and Description
OutputBunch(int outputCount, ActorRef impl, Pump pump)

Method Summary

Modifier and Type	Method and 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

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

isPending

public boolean isPending(int output)

isCompleted

public boolean isCompleted(int output)

isCancelled

public boolean isCancelled(int output)

isErrored

public boolean isErrored(int output)

complete

public void complete()

complete

public void complete(int output)

cancel

public void cancel(java.lang.Throwable e)

error

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

markOutput

public void markOutput(int output)

unmarkOutput

public void unmarkOutput(int output)

markAllOutputs

public void markAllOutputs()

unmarkAllOutputs

public void unmarkAllOutputs()

unmarkCancelledOutputs

public void unmarkCancelledOutputs(boolean enabled)

idToEnqueue

public int idToEnqueue()

enqueue

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

enqueueMarked

public void enqueueMarked(java.lang.Object elem)

idToEnqueueAndYield

public int idToEnqueueAndYield()

enqueueAndYield

public void enqueueAndYield(java.lang.Object elem)

enqueueAndPrefer

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

onCancel

public void onCancel(int output)

demandAvailableFor

public java.lang.Object demandAvailableFor(int id)

demandOrCancelAvailableFor

public java.lang.Object demandOrCancelAvailableFor(int id)

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)

subreceive

public SubReceive subreceive()