Package akka.stream.impl
Interface Inputs
-
- All Known Subinterfaces:
DefaultInputTransferStates
- All Known Implementing Classes:
BatchingInputBuffer
public interface InputsINTERNAL API
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidcancel()java.lang.ObjectdequeueInputElement()booleaninputsAvailable()booleaninputsDepleted()booleanisClosed()booleanisOpen()TransferStateNeedsInput()TransferStateNeedsInputOrComplete()SubReceivesubreceive()
-
-
-
Method Detail
-
NeedsInput
TransferState NeedsInput()
-
NeedsInputOrComplete
TransferState NeedsInputOrComplete()
-
cancel
void cancel()
-
dequeueInputElement
java.lang.Object dequeueInputElement()
-
inputsAvailable
boolean inputsAvailable()
-
inputsDepleted
boolean inputsDepleted()
-
isClosed
boolean isClosed()
-
isOpen
boolean isOpen()
-
subreceive
SubReceive subreceive()
-
-