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

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()

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.stream.impl.Inputs

isOpen

Constructor Detail

BatchingInputBuffer

public BatchingInputBuffer(int size,
                           Pump pump)

Method Detail

NeedsInput

public TransferState NeedsInput()

Specified by:

NeedsInput in interface DefaultInputTransferStates

Specified by:

NeedsInput in interface Inputs

NeedsInputOrComplete

public TransferState NeedsInputOrComplete()

Specified by:

NeedsInputOrComplete in interface DefaultInputTransferStates

Specified by:

NeedsInputOrComplete in interface Inputs

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 interface DefaultInputTransferStates

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 interface DefaultInputTransferStates

cancel

public void cancel()

Specified by:

cancel in interface Inputs

completed

protected scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> completed()

dequeueInputElement

public java.lang.Object dequeueInputElement()

Specified by:

dequeueInputElement in interface Inputs

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 interface Inputs

inputsDepleted

public boolean inputsDepleted()

Specified by:

inputsDepleted in interface Inputs

isClosed

public boolean isClosed()

Specified by:

isClosed in interface Inputs

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 interface Inputs

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

upstreamRunning

protected scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> upstreamRunning()

waitingForUpstream

protected scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> waitingForUpstream()