Package akka.stream.impl.streamref
-
Interface Summary Interface Description SinkRefStageImpl.ActorRefStage SourceRefStageImpl.ActorRefStage SourceRefStageImpl.State SourceRefStageImpl.WeKnowPartner 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 backingSinkRefs.SinkRefStageImpl$ INTERNAL APISourceRefImpl<T> INTERNAL API: Implementation class, not intended to be touched directly by end-usersSourceRefImpl$ SourceRefStageImpl<Out> INTERNAL API: Actual operator implementation backingSourceRefs.SourceRefStageImpl.WatermarkRequestStrategy SourceRefStageImpl.WatermarkRequestStrategy$ SourceRefStageImpl$ INTERNAL APIStreamRefResolverImpl INTERNAL APIStreamRefSettingsImpl INTERNAL APIStreamRefSettingsImpl$ StreamRefsMaster INTERNAL APIStreamRefsMaster$ INTERNAL APIStreamRefsProtocol.Ack$ INTERNAL APIStreamRefsProtocol.CumulativeDemand INTERNAL API: Cumulative demand, equivalent to sequence numbering all events in a stream.StreamRefsProtocol.CumulativeDemand$ StreamRefsProtocol.OnSubscribeHandshake INTERNAL API: Initial message sent to remote side to establish partnership between origin and remote stream refs.StreamRefsProtocol.OnSubscribeHandshake$ StreamRefsProtocol.RemoteStreamCompleted INTERNAL APIStreamRefsProtocol.RemoteStreamCompleted$ StreamRefsProtocol.RemoteStreamFailure INTERNAL APIStreamRefsProtocol.RemoteStreamFailure$ StreamRefsProtocol.SequencedOnNext<T> SequencedSubscriber#onNextequivalent.StreamRefsProtocol.SequencedOnNext$ StreamRefsProtocol$ INTERNAL API