Package akka.stream.impl
Interface Outputs
-
- All Known Subinterfaces:
DefaultOutputTransferStates
- All Known Implementing Classes:
FanOut.FanoutOutputs,FanoutOutputs,SimpleOutputs
public interface OutputsINTERNAL API
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidcancel()voidcomplete()booleandemandAvailable()longdemandCount()voidenqueueOutputElement(java.lang.Object elem)voiderror(java.lang.Throwable e)booleanisClosed()booleanisOpen()TransferStateNeedsDemand()TransferStateNeedsDemandOrCancel()SubReceivesubreceive()
-
-
-
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()
-
-