public abstract class BatchingInputBuffer extends java.lang.Object implements DefaultInputTransferStates
Constructor and Description |
---|
BatchingInputBuffer(int size,
Pump pump) |
Modifier and Type | Method and Description |
---|---|
void |
cancel() |
protected scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
completed() |
java.lang.Object |
dequeueInputElement() |
protected void |
enqueueInputElement(java.lang.Object elem) |
protected void |
inputOnError(java.lang.Throwable e) |
boolean |
inputsAvailable() |
boolean |
inputsDepleted() |
boolean |
isClosed() |
TransferState |
NeedsInput() |
TransferState |
NeedsInputOrComplete() |
protected void |
onComplete() |
protected void |
onError(java.lang.Throwable e) |
protected void |
onSubscribe(org.reactivestreams.Subscription subscription) |
Pump |
pump() |
int |
size() |
SubReceive |
subreceive() |
java.lang.String |
toString() |
protected scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
upstreamRunning() |
protected scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
waitingForUpstream() |
public BatchingInputBuffer(int size, Pump pump)
public TransferState NeedsInput()
NeedsInput
in interface DefaultInputTransferStates
NeedsInput
in interface Inputs
public TransferState NeedsInputOrComplete()
NeedsInputOrComplete
in interface DefaultInputTransferStates
NeedsInputOrComplete
in interface Inputs
public int size()
public Pump pump()
public java.lang.String toString()
toString
in class java.lang.Object
public SubReceive subreceive()
subreceive
in interface Inputs
public java.lang.Object dequeueInputElement()
dequeueInputElement
in interface Inputs
protected final void enqueueInputElement(java.lang.Object elem)
public boolean inputsDepleted()
inputsDepleted
in interface Inputs
public boolean inputsAvailable()
inputsAvailable
in interface Inputs
protected void onComplete()
protected void onSubscribe(org.reactivestreams.Subscription subscription)
protected void onError(java.lang.Throwable e)
protected scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> waitingForUpstream()
protected scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> upstreamRunning()
protected scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> completed()
protected void inputOnError(java.lang.Throwable e)