Package akka.stream.impl

Interface Summary

Interface	Description
ActorRefBackpressureSource.ActorRefStage
ActorRefSource.ActorRefStage
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	Default settings for subscription timeouts.
SubFlowImpl.MergeBack<In,F>
SubscriberManagement<T>	called when we are ready to consume more elements from our upstream MUST NOT call pushToDownstream
SubscriberManagement.EndOfStream
SubscriptionWithCursor<T>	Do not increment directly, use `moreRequested(Long)` instead (it provides overflow protection)!
TransferState	INTERNAL API
Traversal	Concatenates two traversals building a new Traversal which traverses both.
TraversalBuilder	Adds a module to the builder.
TraversalBuildStep	INTERNAL API
VirtualProcessor.HasActualSubscriber
VirtualProcessor.WrappedSubscription$.SubscriptionState

Class Summary

Class	Description
ActorProcessor<I,O>	INTERNAL API
ActorProcessor$	INTERNAL API
ActorProcessorImpl	Subclass may override ActorProcessorImpl.activeReceive()
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
ActorRefBackpressureSource<T>	INTERNAL API
ActorRefBackpressureSource$
ActorRefSink<In>	INTERNAL API
ActorRefSinkActor	INTERNAL API
ActorRefSinkActor$	INTERNAL API
ActorRefSource<T>	INTERNAL API
ActorRefSource$
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
AppendTraversal	INTERNAL API
AppendTraversal$
AtomicTraversalBuilder	INTERNAL API
AtomicTraversalBuilder$
BatchingInputBuffer	INTERNAL API
BoundedBuffer<T>	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	Convert this builder to a CompletedTraversalBuilder if there are no more unwired outputs.
CompositeTraversalBuilder$
Concat
Concat$	An optimizatzion to remove cheaply recognizable patterns of redundancy, for example PushNotUsed immediately followed by a Pop.
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	INTERNAL API
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$	Will only transfer an element when all marked outputs have demand, and will complete as soon as any of the marked outputs have canceled.
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$	Create a traversal builder specialized for linear graphs.
MaterializeAtomic	INTERNAL API
MaterializeAtomic$
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>	The number of elements currently in the buffer.
ResizableMultiReaderRingBuffer$	INTERNAL API
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>	Create the Subscriber or VirtualPublisher that consumes the incoming stream, plus the materialized value.
SinkModuleIslandTag	INTERNAL API
SinkModuleIslandTag$	INTERNAL API
SinkModulePhase	INTERNAL API
SinkQueueAdapter<T>	INTERNAL API
SourceModule<Out,Mat>	INTERNAL API
SourceModuleIslandTag	INTERNAL API
SourceModuleIslandTag$	INTERNAL API
SourceModulePhase	INTERNAL API
SourceQueueAdapter<T>	INTERNAL API
Stages	INTERNAL API
Stages.DefaultAttributes$
Stages$	INTERNAL API
StreamLayout	This is the only extension point for the sealed type hierarchy: composition (i.e.
StreamLayout$	This is the only extension point for the sealed type hierarchy: composition (i.e.
StreamSubscriptionTimeoutSupport.CancelingSubscriber$
StreamSubscriptionTimeoutSupport.NoopSubscriptionTimeout$
StreamSubscriptionTimeoutSupport$	A subscriber who calls cancel directly from onSubscribe and ignores all other callbacks.
StreamSupervisor	INTERNAL API
StreamSupervisor.AddFunctionRef
StreamSupervisor.AddFunctionRef$
StreamSupervisor.Children
StreamSupervisor.Children$
StreamSupervisor.ChildrenSnapshots
StreamSupervisor.ChildrenSnapshots$
StreamSupervisor.GetChildren$
StreamSupervisor.GetChildrenSnapshots$
StreamSupervisor.Materialize
StreamSupervisor.Materialize$
StreamSupervisor.RemoveFunctionRef
StreamSupervisor.RemoveFunctionRef$
StreamSupervisor.StopChildren$
StreamSupervisor.StoppedChildren$
StreamSupervisor$	Testing purpose
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	Given a timeout computes how often the check should be run without causing excessive load or losing timeout precision.
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$	Given a timeout computes how often the check should be run without causing excessive load or losing timeout precision.
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