public interface Outputs
Modifier and Type | Method and 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() |
TransferState NeedsDemand()
TransferState NeedsDemandOrCancel()
boolean demandAvailable()
void enqueueOutputElement(java.lang.Object elem)
SubReceive subreceive()
long demandCount()
void complete()
void cancel()
void error(java.lang.Throwable e)
boolean isClosed()
boolean isOpen()