Package akka.stream.impl
Interface Inputs
-
- All Known Subinterfaces:
DefaultInputTransferStates
- All Known Implementing Classes:
BatchingInputBuffer
public interface Inputs
INTERNAL API
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
cancel()
java.lang.Object
dequeueInputElement()
boolean
inputsAvailable()
boolean
inputsDepleted()
boolean
isClosed()
boolean
isOpen()
TransferState
NeedsInput()
TransferState
NeedsInputOrComplete()
SubReceive
subreceive()
-
-
-
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()
-
-