Package akka.stream.impl.streamref

Interface Summary

Interface	Description
SinkRefStageImpl.ActorRefStage
SourceRefStageImpl.ActorRefStage
StreamRefsProtocol	INTERNAL API

Class Summary

Class	Description
SinkRefImpl<In>	INTERNAL API: Implementation class, not intended to be touched directly by end-users
SinkRefImpl$
SinkRefStageImpl<In>	INTERNAL API: Actual operator implementation backing SinkRefs.
SinkRefStageImpl$	INTERNAL API
SourceRefImpl<T>	INTERNAL API: Implementation class, not intended to be touched directly by end-users
SourceRefImpl$
SourceRefStageImpl<Out>
SourceRefStageImpl.WatermarkRequestStrategy
SourceRefStageImpl.WatermarkRequestStrategy$
SourceRefStageImpl$	Create WatermarkRequestStrategy with lowWatermark as half of the specified highWatermark.
StreamRefResolverImpl	INTERNAL API
StreamRefSettingsImpl	INTERNAL API
StreamRefSettingsImpl$
StreamRefsMaster	INTERNAL API
StreamRefsMaster$	INTERNAL API
StreamRefsProtocol.CumulativeDemand
StreamRefsProtocol.CumulativeDemand$
StreamRefsProtocol.OnSubscribeHandshake
StreamRefsProtocol.OnSubscribeHandshake$
StreamRefsProtocol.RemoteStreamCompleted
StreamRefsProtocol.RemoteStreamCompleted$
StreamRefsProtocol.RemoteStreamFailure
StreamRefsProtocol.RemoteStreamFailure$
StreamRefsProtocol.SequencedOnNext<T>
StreamRefsProtocol.SequencedOnNext$
StreamRefsProtocol$	Sequenced Subscriber#onNext equivalent.