ActorProcessor<I,O> |
INTERNAL API
|
ActorProcessor$ |
INTERNAL API
|
ActorProcessorImpl |
|
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 |
|
CompositeTraversalBuilder$ |
|
Concat |
|
Concat$ |
An optimizatzion to remove cheaply recognizable patterns of redundancy, for example PushNotUsed immediately
followed by a Pop.
|
ConstantFun |
Deprecated.
|
ConstantFun$ |
Deprecated.
|
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$ |
|
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$ |
|