Package akka.stream.impl.streamref
-
Interface Summary Interface Description StreamRefsProtocol INTERNAL API -
Class Summary Class Description SinkRefImpl<In> INTERNAL API: Implementation class, not intended to be touched directly by end-usersSinkRefImpl$ SinkRefStageImpl<In> INTERNAL API: Actual operator implementation backingSinkRef
s.SourceRefImpl<T> INTERNAL API: Implementation class, not intended to be touched directly by end-usersSourceRefImpl$ SourceRefStageImpl<Out> StreamRefResolverImpl INTERNAL APIStreamRefSettingsImpl INTERNAL APIStreamRefSettingsImpl$ StreamRefsMaster INTERNAL APIStreamRefsMaster$ INTERNAL APIStreamRefsProtocol.CumulativeDemand StreamRefsProtocol.CumulativeDemand$ StreamRefsProtocol.OnSubscribeHandshake StreamRefsProtocol.OnSubscribeHandshake$ StreamRefsProtocol.RemoteStreamCompleted StreamRefsProtocol.RemoteStreamCompleted$ StreamRefsProtocol.RemoteStreamFailure StreamRefsProtocol.RemoteStreamFailure$ StreamRefsProtocol.SequencedOnNext<T> StreamRefsProtocol.SequencedOnNext$ StreamRefsProtocol$ SequencedSubscriber#onNext
equivalent.