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
All Methods Instance Methods Abstract Methods Concrete Methods 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)
-
-
-
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 classjava.lang.Object
-
unmarkAllInputs
public void unmarkAllInputs()
-
unmarkInput
public void unmarkInput(int input)
-
-