Package akka.stream.impl

Interface Summary

Interface	Description
Buffer<T>	INTERNAL API
DefaultInputTransferStates	INTERNAL API
DefaultOutputTransferStates	INTERNAL API
Inputs	INTERNAL API
Outputs	INTERNAL API
Pump	INTERNAL API
QueueSink.Output<T>
QueueSource.Input<T>
ReactiveStreamsCompliance.SpecViolation
ResizableMultiReaderRingBuffer.Cursor
ResizableMultiReaderRingBuffer.Cursors
SoftShutdown	INTERNAL API
Stages.SymbolicStage<In,Out>
StreamLayout.MaterializedValueNode
StreamLayout.Module
StreamSubscriptionTimeoutSupport	INTERNAL API Provides support methods to create Publishers and Subscribers which time-out gracefully, and are canceled subscribing an CancellingSubscriber to the publisher, or by calling onError on the timed-out subscriber.
SubFlowImpl.MergeBack<In,F>
SubscriberManagement<T>	INTERNAL API
SubscriberManagement.EndOfStream
SubscriptionWithCursor<T>	INTERNAL API
TransferState	INTERNAL API
VirtualProcessor.WrappedSubscription$.SubscriptionState

Class Summary

Class	Description
ActorMaterializerImpl	INTERNAL API
ActorMaterializerImpl$
ActorProcessor<I,O>	INTERNAL API
ActorProcessor$	INTERNAL API
ActorProcessorImpl	INTERNAL API
ActorPublisher<T>	INTERNAL API
ActorPublisher$	INTERNAL API
ActorPublisherSource<Out>	INTERNAL API Creates and wraps an actor into Publisher from the given props, which should be Props for an ActorPublisher.
ActorRefBackpressureSinkStage<In>	INTERNAL API
ActorRefSink<In>	INTERNAL API
ActorRefSinkActor	INTERNAL API
ActorRefSinkActor$	INTERNAL API
ActorRefSource<Out>	INTERNAL API
ActorRefSourceActor	INTERNAL API
ActorRefSourceActor$	INTERNAL API
ActorSubscriberSink<In>	INTERNAL API Creates and wraps an actor into Subscriber from the given props, which should be Props for an ActorSubscriber.
ActorSubscription<T>	INTERNAL API
ActorSubscriptionWithCursor<T>	INTERNAL API
Always	INTERNAL API
Always$	INTERNAL API
BatchingInputBuffer	INTERNAL API
BoundedBuffer<T>	INTERNAL API
Buffer$
Cancel	INTERNAL API
Cancel$
CancelledSubscription	INTERNAL API This is only a legal subscription when it is immediately followed by a termination signal (onComplete, onError).
CancelledSubscription$	INTERNAL API This is only a legal subscription when it is immediately followed by a termination signal (onComplete, onError).
CancellingSubscriber<T>
CancelSink	INTERNAL API A sink that immediately cancels its upstream upon materialization.
CollectorState<T,R>
Completed	INTERNAL API
Completed$	INTERNAL API
ConstantFun
ConstantFun$
EmptyPublisher	INTERNAL API
EmptyPublisher$	INTERNAL API
EmptySource	INTERNAL API
EmptySource$	INTERNAL API
ErrorPublisher	INTERNAL API
ErrorPublisher$
ExposedPublisher	INTERNAL API
ExposedPublisher$
ExposedPublisherReceive	INTERNAL API
ExtendedActorMaterializer	ExtendedActorMaterializer used by subtypes which materializer using GraphInterpreterShell
FanIn	INTERNAL API
FanIn.InputBunch
FanIn.OnComplete
FanIn.OnComplete$
FanIn.OnError
FanIn.OnError$
FanIn.OnNext
FanIn.OnNext$
FanIn.OnSubscribe
FanIn.OnSubscribe$
FanIn.SubInput<T>
FanIn.SubInput$
FanIn$	INTERNAL API
FanOut	INTERNAL API
FanOut.ExposedPublishers
FanOut.ExposedPublishers$
FanOut.FanoutOutputs
FanOut.OutputBunch
FanOut.SubstreamCancel
FanOut.SubstreamCancel$
FanOut.SubstreamRequestMore
FanOut.SubstreamRequestMore$
FanOut.SubstreamSubscribePending
FanOut.SubstreamSubscribePending$
FanOut.SubstreamSubscription
FanOut$	INTERNAL API
FanoutOutputs	INTERNAL API
FanoutProcessorImpl	INTERNAL API
FanoutProcessorImpl$
FanoutPublisherSink<In>	INTERNAL API
FixedSizeBuffer	INTERNAL API
FixedSizeBuffer.FixedSizeBuffer<T>
FixedSizeBuffer.ModuloFixedSizeBuffer<T>
FixedSizeBuffer.PowerOfTwoFixedSizeBuffer<T>
FixedSizeBuffer$	INTERNAL API
FlowNames	INTERNAL API
FlowNames$	INTERNAL API
HeadOptionStage<T>
JavaStreamSource<T,S extends java.util.stream.BaseStream<T,S>>	Internal API
JsonObjectParser
JsonObjectParser$	INTERNAL API: Use JsonFraming instead.
LastOptionStage<T>
LazySink<T,M>
LazySource<T,M>	INTERNAL API
LazySource$	INTERNAL API
MaterializerSession	INTERNAL API
MaterializerSession$	INERNAL API
MaybePublisher<T>	INTERNAL API
MaybePublisher$
MaybeSource<Out>	INTERNAL API
NotInitialized	INTERNAL API
NotInitialized$	INTERNAL API
ProcessorModule<In,Out,Mat>	INTERNAL API
ProcessorModule$
PublisherSink<In>	INTERNAL API Holds the downstream-most Publisher interface of the materialized flow.
PublisherSource<Out>	INTERNAL API Construct a transformation starting with given publisher.
QueueSink<T>	INTERNAL API
QueueSink.Cancel$
QueueSink.Pull<T>
QueueSink.Pull$
QueueSink$
QueueSource<T>	INTERNAL API
QueueSource.Completion$
QueueSource.Failure
QueueSource.Failure$
QueueSource.Offer<T>
QueueSource.Offer$
QueueSource$	INTERNAL API
ReactiveStreamsCompliance	INTERNAL API
ReactiveStreamsCompliance$	INTERNAL API
ReducerState<T,R>
RejectAdditionalSubscribers	INTERNAL API
RejectAdditionalSubscribers$	INTERNAL API
RequestMore	INTERNAL API
RequestMore$
ResizableMultiReaderRingBuffer<T>	INTERNAL API A mutable RingBuffer that can grow in size and supports multiple readers.
ResizableMultiReaderRingBuffer$	INTERNAL API
SeqActorName	INTERNAL API As discussed in https://github.com/akka/akka/issues/16613
SeqActorName$
SeqActorNameImpl
SeqStage<T>
SimpleOutputs	INTERNAL API
SinkholeSubscriber<T>	INTERNAL API
SinkModule<In,Mat>	INTERNAL API
SinkQueueAdapter<T>
SourceModule<Out,Mat>	INTERNAL API
SourceQueueAdapter<T>
Stages	INTERNAL API
Stages.DefaultAttributes$
Stages.SymbolicGraphStage<In,Out,Ext>
Stages.SymbolicGraphStage$
Stages$	INTERNAL API
StreamLayout	INTERNAL API
StreamLayout.Atomic
StreamLayout.Atomic$
StreamLayout.AtomicModule	This is the only extension point for the sealed type hierarchy: composition (i.e.
StreamLayout.Combine
StreamLayout.Combine$
StreamLayout.CompositeModule
StreamLayout.CompositeModule$
StreamLayout.CopiedModule
StreamLayout.CopiedModule$
StreamLayout.EmptyModule$
StreamLayout.FusedModule
StreamLayout.FusedModule$
StreamLayout.IgnorableMatValComp$
StreamLayout.Ignore$
StreamLayout.StructuralInfoModule	INTERNAL API
StreamLayout.StructuralInfoModule$
StreamLayout.Transform
StreamLayout.Transform$
StreamLayout$	INTERNAL API
StreamSubscriptionTimeoutSupport.CancelingSubscriber$	A subscriber who calls cancel directly from onSubscribe and ignores all other callbacks.
StreamSubscriptionTimeoutSupport.NoopSubscriptionTimeout$	INTERNAL API
StreamSubscriptionTimeoutSupport$
StreamSupervisor
StreamSupervisor.Children	Testing purpose
StreamSupervisor.Children$
StreamSupervisor.GetChildren$	Testing purpose
StreamSupervisor.Materialize
StreamSupervisor.Materialize$
StreamSupervisor.PrintDebugDump$	Testing purpose
StreamSupervisor.StopChildren$	Testing purpose
StreamSupervisor.StoppedChildren$	Testing purpose
StreamSupervisor$	INTERNAL API
SubFlowImpl<In,Out,Mat,F,C>
SubFlowImpl$
SubFusingActorMaterializerImpl
SubReceive	INTERNAL API
SubscribePending	INTERNAL API
SubscribePending$	INTERNAL API
SubscriberManagement.Completed$
SubscriberManagement.ErrorCompleted
SubscriberManagement.ErrorCompleted$
SubscriberManagement.NotReached$
SubscriberManagement$	INTERNAL API
SubscriberSink<In>	INTERNAL API Attaches a subscriber to this stream.
SubscriberSource<Out>	INTERNAL API Holds a Subscriber representing the input side of the flow.
Throttle<T>	INTERNAL API
Timers	INTERNAL API
Timers.BackpressureTimeout<T>
Timers.Completion<T>
Timers.DelayInitial<T>
Timers.GraphStageLogicTimer$
Timers.Idle<T>
Timers.IdleInject<I,O>
Timers.IdleTimeoutBidi<I,O>
Timers.Initial<T>
Timers$	INTERNAL API
TransferPhase	INTERNAL API
TransferPhase$
Unfold<S,E>	INTERNAL API
UnfoldAsync<S,E>	INTERNAL API
UnfoldResourceSource<T,S>	INTERNAL API
UnfoldResourceSourceAsync<T,S>	INTERNAL API
Unzip	INTERNAL API
Unzip$	INTERNAL API
VirtualProcessor<T>	INTERNAL API
VirtualProcessor.Both
VirtualProcessor.Both$
VirtualProcessor.Inert$
VirtualProcessor$	INTERNAL API
VirtualPublisher<T>	INTERNAL API
WaitingForUpstreamSubscription	INTERNAL API
WaitingForUpstreamSubscription$

Exception Summary

Exception	Description
ActorPublisher.NormalShutdownException
MaterializerSession.MaterializationPanic
ReactiveStreamsCompliance.SignalThrewException
ResizableMultiReaderRingBuffer.NothingToReadException$
SubscriptionTimeoutException	INTERNAL API