akka.stream.impl

Interface DefaultOutputTransferStates

All Superinterfaces:

Outputs

All Known Implementing Classes:

FanOut.FanoutOutputs, FanoutOutputs, SimpleOutputs

public interface DefaultOutputTransferStates
extends Outputs

INTERNAL API

Method Summary

Modifier and Type	Method and Description
TransferState	NeedsDemand()
TransferState	NeedsDemandOrCancel()

Methods inherited from interface akka.stream.impl.Outputs

cancel, complete, demandAvailable, demandCount, enqueueOutputElement, error, isClosed, isOpen, subreceive

Method Detail

NeedsDemand

TransferState NeedsDemand()

Specified by:

NeedsDemand in interface Outputs

NeedsDemandOrCancel

TransferState NeedsDemandOrCancel()

Specified by:

NeedsDemandOrCancel in interface Outputs