Package akka.stream.impl.streamref
Interface StreamRefsProtocol
-
- All Known Implementing Classes:
StreamRefsProtocol.Ack$
,StreamRefsProtocol.CumulativeDemand
,StreamRefsProtocol.OnSubscribeHandshake
,StreamRefsProtocol.RemoteStreamCompleted
,StreamRefsProtocol.RemoteStreamFailure
,StreamRefsProtocol.SequencedOnNext
public interface StreamRefsProtocol
INTERNAL API
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static class
StreamRefsProtocol.Ack$
INTERNAL APIstatic class
StreamRefsProtocol.CumulativeDemand
INTERNAL API: Cumulative demand, equivalent to sequence numbering all events in a stream.static class
StreamRefsProtocol.CumulativeDemand$
static class
StreamRefsProtocol.OnSubscribeHandshake
INTERNAL API: Initial message sent to remote side to establish partnership between origin and remote stream refs.static class
StreamRefsProtocol.OnSubscribeHandshake$
static class
StreamRefsProtocol.RemoteStreamCompleted
INTERNAL APIstatic class
StreamRefsProtocol.RemoteStreamCompleted$
static class
StreamRefsProtocol.RemoteStreamFailure
INTERNAL APIstatic class
StreamRefsProtocol.RemoteStreamFailure$
static class
StreamRefsProtocol.SequencedOnNext<T>
SequencedSubscriber#onNext
equivalent.static class
StreamRefsProtocol.SequencedOnNext$
-