Package akka.stream.impl.streamref
Interface StreamRefsProtocol
-
- All Known Implementing Classes:
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.CumulativeDemand
static class
StreamRefsProtocol.CumulativeDemand$
static class
StreamRefsProtocol.OnSubscribeHandshake
static class
StreamRefsProtocol.OnSubscribeHandshake$
static class
StreamRefsProtocol.RemoteStreamCompleted
static class
StreamRefsProtocol.RemoteStreamCompleted$
static class
StreamRefsProtocol.RemoteStreamFailure
static class
StreamRefsProtocol.RemoteStreamFailure$
static class
StreamRefsProtocol.SequencedOnNext<T>
static class
StreamRefsProtocol.SequencedOnNext$
-