Package akka.stream.impl

Interface Summary

Interface	Description
ActorRefBackpressureSource.ActorRefStage
ActorRefSource.ActorRefStage
BoundedSourceQueueStage.State
Buffer<T>	INTERNAL API
CollectorState<T,R>	INTERNAL API
DefaultInputTransferStates	INTERNAL API
DefaultOutputTransferStates	INTERNAL API
Inputs	INTERNAL API
IslandTag	INTERNAL API
MaterializedValueOp	INTERNAL API
Outputs	INTERNAL API
Phase<M>	INTERNAL API
PhaseIsland<M>	INTERNAL API
Pump	INTERNAL API
QueueSink.Output<T>
QueueSource.Input<T>
ReactiveStreamsCompliance.SpecViolation
ReducerState<T,R>	INTERNAL API
ResizableMultiReaderRingBuffer.Cursor
ResizableMultiReaderRingBuffer.Cursors
SoftShutdown	INTERNAL API
StreamLayout.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 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
Traversal	INTERNAL API
TraversalBuilder	INTERNAL API
TraversalBuildStep	INTERNAL API
VirtualProcessor.HasActualSubscriber
VirtualProcessor.WrappedSubscription$.SubscriptionState

Class Summary

Class	Description
ActorProcessor<I,O>	INTERNAL API
ActorProcessor$	INTERNAL API
ActorProcessorImpl	INTERNAL API
ActorProcessorImpl.SubscriptionTimeout$
ActorProcessorImpl$
ActorPublisher<T>	INTERNAL API
ActorPublisher$	INTERNAL API
ActorRefBackpressureSinkStage<In>	INTERNAL API
ActorRefBackpressureSource<T>	INTERNAL API
ActorRefBackpressureSource$
ActorRefSinkStage<T>	INTERNAL API
ActorRefSource<T>	INTERNAL API
ActorRefSource$
ActorSubscriberMessage	INTERNAL API
ActorSubscriberMessage.OnComplete$
ActorSubscriberMessage.OnError
ActorSubscriberMessage.OnError$
ActorSubscriberMessage.OnNext
ActorSubscriberMessage.OnNext$
ActorSubscriberMessage.OnSubscribe
ActorSubscriberMessage.OnSubscribe$
ActorSubscriberMessage$	INTERNAL API
ActorSubscription<T>	INTERNAL API
ActorSubscriptionWithCursor<T>	INTERNAL API
Always	INTERNAL API
Always$	INTERNAL API
AppendTraversal	INTERNAL API
AppendTraversal$
AtomicTraversalBuilder	INTERNAL API
AtomicTraversalBuilder$
BatchingInputBuffer	INTERNAL API
BoundedBuffer<T>	INTERNAL API
BoundedSourceQueueStage<T>	INTERNAL API
BoundedSourceQueueStage.Done
BoundedSourceQueueStage.Done$
BoundedSourceQueueStage.NeedsActivation$
BoundedSourceQueueStage.Running$
BoundedSourceQueueStage$	INTERNAL API
Buffer$
BuilderKey	INTERNAL API
Cancel<T>	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>	INTERNAL API
CancelSink	INTERNAL API A sink that immediately cancels its upstream upon materialization.
Completed	INTERNAL API
Completed$	INTERNAL API
CompletedTraversalBuilder	INTERNAL API
CompletedTraversalBuilder$
Compose	INTERNAL API
Compose$
CompositeTraversalBuilder	INTERNAL API
CompositeTraversalBuilder$
Concat
Concat$	INTERNAL API
ConstantFun	Deprecated. Use akka.util.ConstantFun instead.
ConstantFun$	Deprecated. Use akka.util.ConstantFun instead.
EmptyPublisher	INTERNAL API
EmptyPublisher$	INTERNAL API
EmptySource	INTERNAL API
EmptySource$	INTERNAL API
EmptyTraversal	INTERNAL API
EmptyTraversal$	INTERNAL API
EnterIsland	INTERNAL API
EnterIsland$
ErrorPublisher	INTERNAL API
ErrorPublisher$
ExitIsland	INTERNAL API
ExitIsland$	INTERNAL API
ExposedPublisher	INTERNAL API
ExposedPublisher$
ExposedPublisherReceive	INTERNAL API
ExtendedActorMaterializer	ExtendedActorMaterializer used by subtypes which delegates in-island wiring to PhaseIslands
FailedSource<T>	INTERNAL API
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$	INTERNAL API
FanoutPublisherSink<In>	INTERNAL API
FirstCollectorState<T,R>	INTERNAL API
FirstReducerState<T,R>	INTERNAL API
FixedSizeBuffer	INTERNAL API
FixedSizeBuffer.ModuloFixedSizeBuffer<T>
FixedSizeBuffer.PowerOfTwoFixedSizeBuffer<T>
FixedSizeBuffer$	INTERNAL API
FixedSizeBuffer$FixedSizeBuffer<T>
FlowNames	INTERNAL API
FlowNames$	INTERNAL API
ForwardWire
ForwardWire$
GraphStageIsland	INTERNAL API
GraphStageTag	INTERNAL API
GraphStageTag$	INTERNAL API
HeadOptionStage<T>	INTERNAL API
IslandTracking
JavaStreamSource<T,S extends java.util.stream.BaseStream<T,S>>	INTERNAL API
JsonObjectParser
JsonObjectParser$	INTERNAL API: Use JsonFraming instead.
LazySink<T,M>	INTERNAL API
LazySource<T,M>	INTERNAL API
LazySource$	INTERNAL API
LinearTraversalBuilder
LinearTraversalBuilder$	INTERNAL API
MaterializeAtomic	INTERNAL API
MaterializeAtomic$
MaterializerGuardian	INTERNAL API
MaterializerGuardian.LegacyStartMaterializer
MaterializerGuardian.LegacyStartMaterializer$
MaterializerGuardian.MaterializerStarted
MaterializerGuardian.MaterializerStarted$
MaterializerGuardian.StartMaterializer$
MaterializerGuardian$	INTERNAL API
MaybeSource	INTERNAL API
MaybeSource$	INTERNAL API
MutableCollectorState<T,R>	INTERNAL API
MutableReducerState<T,R>	INTERNAL API
NotInitialized	INTERNAL API
NotInitialized$	INTERNAL API
PhasedFusingActorMaterializer
PhasedFusingActorMaterializer$	INTERNAL API
Pop	INTERNAL API
Pop$	INTERNAL API
PopAttributes	INTERNAL API
PopAttributes$	INTERNAL API
ProcessorModule<In,Out,Mat>	INTERNAL API
ProcessorModule$
ProcessorModuleIslandTag	INTERNAL API
ProcessorModuleIslandTag$	INTERNAL API
ProcessorModulePhase	INTERNAL API
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.
PushAttributes	INTERNAL API
PushAttributes$
PushNotUsed	INTERNAL API
PushNotUsed$	INTERNAL API
QueueSink<T>	INTERNAL API
QueueSink.Cancel$
QueueSink.Pull<T>
QueueSink.Pull$
QueueSink$	INTERNAL API
QueueSource<T>	INTERNAL API
QueueSource.Completion$
QueueSource.Failure
QueueSource.Failure$
QueueSource.Offer<T>
QueueSource.Offer$
QueueSource$	INTERNAL API
ReactiveStreamsCompliance	INTERNAL API
ReactiveStreamsCompliance$	INTERNAL API
RejectAdditionalSubscribers	INTERNAL API
RejectAdditionalSubscribers$	INTERNAL API
RequestMore<T>	INTERNAL API
RequestMore$
ResizableMultiReaderRingBuffer<T>	INTERNAL API A mutable RingBuffer that can grow in size and supports multiple readers.
ResizableMultiReaderRingBuffer$	INTERNAL API
RetryFlowCoordinator<In,Out>	INTERNAL API.
RetryFlowCoordinator.RetryCurrentElement$
RetryFlowCoordinator$
SavedIslandData
SavedIslandData$
SegmentInfo
SegmentInfo$
SeqActorName	INTERNAL API As discussed in https://github.com/akka/akka/issues/16613
SeqActorName$	INTERNAL API
SeqActorNameImpl	INTERNAL API
SeqStage<T,That>	INTERNAL API
SetupFlowStage<T,U,M>	Internal Api
SetupSinkStage<T,M>	Internal Api
SetupSourceStage<T,M>	Internal Api
SetupStage
SetupStage$
SimpleOutputs	INTERNAL API
SinkholeSubscriber<T>	INTERNAL API
SinkModule<In,Mat>	INTERNAL API
SinkModuleIslandTag	INTERNAL API
SinkModuleIslandTag$	INTERNAL API
SinkModulePhase	INTERNAL API
SnapshotCollector
SnapshotCollector.SnapshotTimeout$
SnapshotCollector$
SourceModule<Out,Mat>	INTERNAL API
SourceModuleIslandTag	INTERNAL API
SourceModuleIslandTag$	INTERNAL API
SourceModulePhase	INTERNAL API
Stages	INTERNAL API
Stages.DefaultAttributes$
Stages$	INTERNAL API
StreamLayout	INTERNAL API
StreamLayout$	INTERNAL API
StreamSubscriptionTimeoutSupport.CancelingSubscriber$	A subscriber who calls cancel directly from onSubscribe and ignores all other callbacks.
StreamSubscriptionTimeoutSupport.NoopSubscriptionTimeout$	INTERNAL API
StreamSubscriptionTimeoutSupport$	INTERNAL API
StreamSupervisor	INTERNAL API
StreamSupervisor.Children	Testing purpose
StreamSupervisor.Children$
StreamSupervisor.ChildrenSnapshots
StreamSupervisor.ChildrenSnapshots$
StreamSupervisor.GetChildren$	Testing purpose
StreamSupervisor.GetChildrenSnapshots
StreamSupervisor.GetChildrenSnapshots$
StreamSupervisor.Materialize
StreamSupervisor.Materialize$
StreamSupervisor.StopChildren$	Testing purpose
StreamSupervisor.StoppedChildren$	Testing purpose
StreamSupervisor$	INTERNAL API
SubFlowImpl<In,Out,Mat,F,C>	INTERNAL API
SubFlowImpl$	INTERNAL API
SubFusingActorMaterializerImpl	This materializer replaces the default phase with one that will fuse operators into an existing interpreter (via registerShell), rather than start a new actor for each of them.
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.
TakeLastStage<T>	INTERNAL API
Throttle<T>	INTERNAL API
Throttle$	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
TlsModuleIslandTag	INTERNAL API
TlsModuleIslandTag$	INTERNAL API
TlsModulePhase	INTERNAL API
TransferPhase	INTERNAL API
TransferPhase$
Transform	INTERNAL API
Transform$
TraversalBuilder$	INTERNAL API
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.Establishing
VirtualProcessor.Establishing$
VirtualProcessor.Inert$
VirtualProcessor$	INTERNAL API
VirtualPublisher<T>	INTERNAL API
WaitingForUpstreamSubscription	INTERNAL API
WaitingForUpstreamSubscription$

Exception Summary

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