public abstract static class FanIn.InputBunch
extends java.lang.Object
Constructor and Description |
---|
InputBunch(int inputCount,
int bufferSize,
Pump pump) |
Modifier and Type | Method and 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) |
public InputBunch(int inputCount, int bufferSize, Pump pump)
public java.lang.String toString()
toString
in class java.lang.Object
public int lastDequeuedId()
public void cancel()
public void cancel(int input)
public abstract void onError(int input, java.lang.Throwable e)
public void onDepleted(int input)
public void onCompleteWhenNoInput()
public void markInput(int input)
public void unmarkInput(int input)
public void markAllInputs()
public void unmarkAllInputs()
public boolean isPending(int input)
public boolean isDepleted(int input)
public boolean isCancelled(int input)
public boolean isAllCompleted()
public int idToDequeue()
public java.lang.Object dequeue(int id)
public java.lang.Object dequeueAndYield()
public java.lang.Object dequeueAndYield(int id)
public java.lang.Object dequeuePreferring(int preferred)
public java.lang.Object AllOfMarkedInputs()
public java.lang.Object AnyOfMarkedInputs()
public java.lang.Object inputsAvailableFor(int id)
public java.lang.Object inputsOrCompleteAvailableFor(int id)
public SubReceive subreceive()