Package akka.stream.impl

Class FanIn.InputBunch

java.lang.Object

akka.stream.impl.FanIn.InputBunch

Enclosing class:

FanIn

public abstract static class FanIn.InputBunch
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
InputBunch(int inputCount, int bufferSize, Pump pump)

Method Summary

Modifier and Type	Method	Description
java.lang.Object	AllOfMarkedInputs()
java.lang.Object	AnyOfMarkedInputs()
void	cancel()
void	cancel(int input)
java.lang.Object	dequeue(int id)
java.lang.Object	dequeueAndYield()
java.lang.Object	dequeueAndYield(int id)
java.lang.Object	dequeuePreferring(int preferred)
int	idToDequeue()
java.lang.Object	inputsAvailableFor(int id)
java.lang.Object	inputsOrCompleteAvailableFor(int id)
boolean	isAllCompleted()
boolean	isCancelled(int input)
boolean	isDepleted(int input)
boolean	isPending(int input)
int	lastDequeuedId()
void	markAllInputs()
void	markInput(int input)
void	onCompleteWhenNoInput()
void	onDepleted(int input)
abstract void	onError(int input, java.lang.Throwable e)
SubReceive	subreceive()
java.lang.String	toString()
void	unmarkAllInputs()
void	unmarkInput(int input)

Methods inherited from class java.lang.Object

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

Constructor Detail

InputBunch

public InputBunch(int inputCount,
                  int bufferSize,
                  Pump pump)

Method Detail

AllOfMarkedInputs

public java.lang.Object AllOfMarkedInputs()

AnyOfMarkedInputs

public java.lang.Object AnyOfMarkedInputs()

cancel

public void cancel()

cancel

public void cancel(int input)

dequeue

public java.lang.Object dequeue(int id)

dequeueAndYield

public java.lang.Object dequeueAndYield()

dequeueAndYield

public java.lang.Object dequeueAndYield(int id)

dequeuePreferring

public java.lang.Object dequeuePreferring(int preferred)

idToDequeue

public int idToDequeue()

inputsAvailableFor

public java.lang.Object inputsAvailableFor(int id)

inputsOrCompleteAvailableFor

public java.lang.Object inputsOrCompleteAvailableFor(int id)

isAllCompleted

public boolean isAllCompleted()

isCancelled

public boolean isCancelled(int input)

isDepleted

public boolean isDepleted(int input)

isPending

public boolean isPending(int input)

lastDequeuedId

public int lastDequeuedId()

markAllInputs

public void markAllInputs()

markInput

public void markInput(int input)

onCompleteWhenNoInput

public void onCompleteWhenNoInput()

onDepleted

public void onDepleted(int input)

onError

public abstract void onError(int input,
                             java.lang.Throwable e)

subreceive

public SubReceive subreceive()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

unmarkAllInputs

public void unmarkAllInputs()

unmarkInput

public void unmarkInput(int input)