Package akka.stream.impl
Class BatchingInputBuffer
- java.lang.Object
-
- akka.stream.impl.BatchingInputBuffer
-
- All Implemented Interfaces:
DefaultInputTransferStates
,Inputs
public abstract class BatchingInputBuffer extends java.lang.Object implements DefaultInputTransferStates
INTERNAL API
-
-
Constructor Summary
Constructors Constructor Description BatchingInputBuffer(int size, Pump pump)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
akka$stream$impl$DefaultInputTransferStates$_setter_$NeedsInput_$eq(TransferState x$1)
protected void
akka$stream$impl$DefaultInputTransferStates$_setter_$NeedsInputOrComplete_$eq(TransferState x$1)
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()
-
-
-
Constructor Detail
-
BatchingInputBuffer
public BatchingInputBuffer(int size, Pump pump)
-
-
Method Detail
-
NeedsInput
public TransferState NeedsInput()
- Specified by:
NeedsInput
in interfaceDefaultInputTransferStates
- Specified by:
NeedsInput
in interfaceInputs
-
NeedsInputOrComplete
public TransferState NeedsInputOrComplete()
- Specified by:
NeedsInputOrComplete
in interfaceDefaultInputTransferStates
- Specified by:
NeedsInputOrComplete
in interfaceInputs
-
akka$stream$impl$DefaultInputTransferStates$_setter_$NeedsInputOrComplete_$eq
protected void akka$stream$impl$DefaultInputTransferStates$_setter_$NeedsInputOrComplete_$eq(TransferState x$1)
- Specified by:
akka$stream$impl$DefaultInputTransferStates$_setter_$NeedsInputOrComplete_$eq
in interfaceDefaultInputTransferStates
-
akka$stream$impl$DefaultInputTransferStates$_setter_$NeedsInput_$eq
protected void akka$stream$impl$DefaultInputTransferStates$_setter_$NeedsInput_$eq(TransferState x$1)
- Specified by:
akka$stream$impl$DefaultInputTransferStates$_setter_$NeedsInput_$eq
in interfaceDefaultInputTransferStates
-
completed
protected scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> completed()
-
dequeueInputElement
public java.lang.Object dequeueInputElement()
- Specified by:
dequeueInputElement
in interfaceInputs
-
enqueueInputElement
protected final void enqueueInputElement(java.lang.Object elem)
-
inputOnError
protected void inputOnError(java.lang.Throwable e)
-
inputsAvailable
public boolean inputsAvailable()
- Specified by:
inputsAvailable
in interfaceInputs
-
inputsDepleted
public boolean inputsDepleted()
- Specified by:
inputsDepleted
in interfaceInputs
-
onComplete
protected void onComplete()
-
onError
protected void onError(java.lang.Throwable e)
-
onSubscribe
protected void onSubscribe(org.reactivestreams.Subscription subscription)
-
pump
public Pump pump()
-
size
public int size()
-
subreceive
public SubReceive subreceive()
- Specified by:
subreceive
in interfaceInputs
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
upstreamRunning
protected scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> upstreamRunning()
-
waitingForUpstream
protected scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> waitingForUpstream()
-
-