akka.stream.impl

Interface DefaultInputTransferStates

All Superinterfaces:

Inputs

All Known Implementing Classes:

BatchingInputBuffer

public interface DefaultInputTransferStates
extends Inputs

INTERNAL API

Method Summary

Modifier and Type	Method and Description
TransferState	NeedsInput()
TransferState	NeedsInputOrComplete()

Methods inherited from interface akka.stream.impl.Inputs

cancel, dequeueInputElement, inputsAvailable, inputsDepleted, isClosed, isOpen, subreceive

Method Detail

NeedsInput

TransferState NeedsInput()

Specified by:

NeedsInput in interface Inputs

NeedsInputOrComplete

TransferState NeedsInputOrComplete()

Specified by:

NeedsInputOrComplete in interface Inputs