Package akka.stream.impl
-
Interface Summary Interface Description ActorRefBackpressureSource.ActorRefStage ActorRefSource.ActorRefStage Buffer<T> INTERNAL APICollectorState<T,R> INTERNAL APIDefaultInputTransferStates INTERNAL APIDefaultOutputTransferStates INTERNAL APIInputs INTERNAL APIIslandTag INTERNAL APIMaterializedValueOp INTERNAL APIOutputs INTERNAL APIPhase<M> INTERNAL APIPhaseIsland<M> INTERNAL APIPump INTERNAL APIQueueSink.Output<T> QueueSource.Input<T> ReactiveStreamsCompliance.SpecViolation ReducerState<T,R> INTERNAL APIResizableMultiReaderRingBuffer.Cursor ResizableMultiReaderRingBuffer.Cursors SoftShutdown INTERNAL APIStreamLayout.AtomicModule<S extends Shape,M> This is the only extension point for the sealed type hierarchy: composition (i.e.StreamSubscriptionTimeoutSupport INTERNAL API Provides support methods to create Publishers and Subscribers which time-out gracefully, and are canceled subscribing anCancellingSubscriberto the publisher, or by callingonErroron the timed-out subscriber.SubFlowImpl.MergeBack<In,F> SubscriberManagement<T> INTERNAL APISubscriberManagement.EndOfStream SubscriptionWithCursor<T> INTERNAL APITransferState INTERNAL APITraversal INTERNAL APITraversalBuilder INTERNAL APITraversalBuildStep INTERNAL APIVirtualProcessor.HasActualSubscriber VirtualProcessor.WrappedSubscription$.SubscriptionState -
Exception Summary Exception Description ActorPublisher.NormalShutdownException ReactiveStreamsCompliance.SignalThrewException ResizableMultiReaderRingBuffer.NothingToReadException$ SubscriptionTimeoutException INTERNAL API