Package akka.stream.impl
Interface Outputs
-
- All Known Subinterfaces:
DefaultOutputTransferStates
- All Known Implementing Classes:
FanOut.FanoutOutputs
,FanoutOutputs
,SimpleOutputs
public interface Outputs
INTERNAL API
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
cancel()
void
complete()
boolean
demandAvailable()
long
demandCount()
void
enqueueOutputElement(java.lang.Object elem)
void
error(java.lang.Throwable e)
boolean
isClosed()
boolean
isOpen()
TransferState
NeedsDemand()
TransferState
NeedsDemandOrCancel()
SubReceive
subreceive()
-
-
-
Method Detail
-
NeedsDemand
TransferState NeedsDemand()
-
NeedsDemandOrCancel
TransferState NeedsDemandOrCancel()
-
cancel
void cancel()
-
complete
void complete()
-
demandAvailable
boolean demandAvailable()
-
demandCount
long demandCount()
-
enqueueOutputElement
void enqueueOutputElement(java.lang.Object elem)
-
error
void error(java.lang.Throwable e)
-
isClosed
boolean isClosed()
-
isOpen
boolean isOpen()
-
subreceive
SubReceive subreceive()
-
-