AbruptIOTerminationException$ |
|
AbruptTerminationException$ |
|
AbstractShape |
Provide the list of all input ports of this shape.
|
ActorAttributes |
INTERNAL API
Resolves the dispatcher's name with a fallback to the default blocking IO dispatcher.
|
ActorAttributes.Dispatcher |
|
ActorAttributes.Dispatcher$ |
|
ActorAttributes.SupervisionStrategy |
|
ActorAttributes.SupervisionStrategy$ |
|
ActorAttributes$ |
INTERNAL API
Resolves the dispatcher's name with a fallback to the default blocking IO dispatcher.
|
ActorMaterializer |
Shuts down this materializer and all the operators that have been materialized through this materializer.
|
ActorMaterializer$ |
Scala API: Creates an ActorMaterializer that can materialize stream blueprints as running streams.
|
ActorMaterializerHelper |
INTERNAL API
|
ActorMaterializerHelper$ |
INTERNAL API
|
ActorMaterializerSettings |
Each asynchronous piece of a materialized stream topology is executed by one Actor
that manages an input buffer for all inlets of its shape.
|
ActorMaterializerSettings$ |
|
AmorphousShape |
This type of Shape can express any number of inputs and outputs at the
expense of forgetting about their specific types.
|
AmorphousShape$ |
|
Attributes |
Note that this must only be used during traversal building and not during materialization
as it will then always return true because of the defaults from the ActorMaterializerSettings
INTERNAL API
|
Attributes.AsyncBoundary$ |
|
Attributes.CancellationStrategy |
|
Attributes.CancellationStrategy$ |
|
Attributes.CancellationStrategy$.AfterDelay |
|
Attributes.CancellationStrategy$.AfterDelay$ |
|
Attributes.CancellationStrategy$.CompleteStage$ |
|
Attributes.CancellationStrategy$.FailStage$ |
|
Attributes.InputBuffer |
|
Attributes.InputBuffer$ |
|
Attributes.LogLevels |
|
Attributes.LogLevels$ |
|
Attributes.Name |
|
Attributes.Name$ |
|
Attributes$ |
Cancellation strategies provide a way to configure the behavior of a stage when cancelStage is called.
|
BidiShape<In1,Out1,In2,Out2> |
Java API for creating from a pair of unidirectional flows.
|
BidiShape$ |
Java API
|
BufferOverflowException$ |
|
Client |
The client is usually the side that consumes the service provided by its
interlocutor.
|
Client$ |
|
ClosedShape |
This Shape is used for graphs that have neither open inputs nor open
outputs.
|
ClosedShape$ |
Java API: obtain ClosedShape instance
|
CompletionStrategy.Draining$ |
|
CompletionStrategy.Immediately$ |
|
CompletionStrategy$ |
INTERNAL API
|
DelayOverflowStrategy |
INTERNAL API
|
DelayOverflowStrategy$ |
If the buffer is full when a new element is available this strategy send next element downstream without waiting
|
EagerClose |
|
EagerClose$ |
|
FanInShape<O> |
Not meant for overriding outside of Akka.
|
FanInShape.Name<O> |
|
FanInShape.Name$ |
|
FanInShape.Ports<O> |
|
FanInShape.Ports$ |
|
FanInShape$ |
|
FanInShape10<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,O> |
|
FanInShape11<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,O> |
|
FanInShape12<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,O> |
|
FanInShape13<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,O> |
|
FanInShape14<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,O> |
|
FanInShape15<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,O> |
|
FanInShape16<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,O> |
|
FanInShape17<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,O> |
|
FanInShape18<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,O> |
|
FanInShape19<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,O> |
|
FanInShape1N<T0,T1,O> |
Deprecated.
|
FanInShape2<T0,T1,O> |
|
FanInShape20<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,O> |
|
FanInShape21<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,O> |
|
FanInShape22<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,O> |
|
FanInShape3<T0,T1,T2,O> |
|
FanInShape4<T0,T1,T2,T3,O> |
|
FanInShape5<T0,T1,T2,T3,T4,O> |
|
FanInShape6<T0,T1,T2,T3,T4,T5,O> |
|
FanInShape7<T0,T1,T2,T3,T4,T5,T6,O> |
|
FanInShape8<T0,T1,T2,T3,T4,T5,T6,T7,O> |
|
FanInShape9<T0,T1,T2,T3,T4,T5,T6,T7,T8,O> |
|
FanOutShape<I> |
Not meant for overriding outside of Akka.
|
FanOutShape.Name<I> |
|
FanOutShape.Name$ |
|
FanOutShape.Ports<I> |
|
FanOutShape.Ports$ |
|
FanOutShape$ |
|
FanOutShape10<I,O0,O1,O2,O3,O4,O5,O6,O7,O8,O9> |
|
FanOutShape11<I,O0,O1,O2,O3,O4,O5,O6,O7,O8,O9,O10> |
|
FanOutShape12<I,O0,O1,O2,O3,O4,O5,O6,O7,O8,O9,O10,O11> |
|
FanOutShape13<I,O0,O1,O2,O3,O4,O5,O6,O7,O8,O9,O10,O11,O12> |
|
FanOutShape14<I,O0,O1,O2,O3,O4,O5,O6,O7,O8,O9,O10,O11,O12,O13> |
|
FanOutShape15<I,O0,O1,O2,O3,O4,O5,O6,O7,O8,O9,O10,O11,O12,O13,O14> |
|
FanOutShape16<I,O0,O1,O2,O3,O4,O5,O6,O7,O8,O9,O10,O11,O12,O13,O14,O15> |
|
FanOutShape17<I,O0,O1,O2,O3,O4,O5,O6,O7,O8,O9,O10,O11,O12,O13,O14,O15,O16> |
|
FanOutShape18<I,O0,O1,O2,O3,O4,O5,O6,O7,O8,O9,O10,O11,O12,O13,O14,O15,O16,O17> |
|
FanOutShape19<I,O0,O1,O2,O3,O4,O5,O6,O7,O8,O9,O10,O11,O12,O13,O14,O15,O16,O17,O18> |
|
FanOutShape2<I,O0,O1> |
|
FanOutShape20<I,O0,O1,O2,O3,O4,O5,O6,O7,O8,O9,O10,O11,O12,O13,O14,O15,O16,O17,O18,O19> |
|
FanOutShape21<I,O0,O1,O2,O3,O4,O5,O6,O7,O8,O9,O10,O11,O12,O13,O14,O15,O16,O17,O18,O19,O20> |
|
FanOutShape22<I,O0,O1,O2,O3,O4,O5,O6,O7,O8,O9,O10,O11,O12,O13,O14,O15,O16,O17,O18,O19,O20,O21> |
|
FanOutShape3<I,O0,O1,O2> |
|
FanOutShape4<I,O0,O1,O2,O3> |
|
FanOutShape5<I,O0,O1,O2,O3,O4> |
|
FanOutShape6<I,O0,O1,O2,O3,O4,O5> |
|
FanOutShape7<I,O0,O1,O2,O3,O4,O5,O6> |
|
FanOutShape8<I,O0,O1,O2,O3,O4,O5,O6,O7> |
|
FanOutShape9<I,O0,O1,O2,O3,O4,O5,O6,O7,O8> |
|
FlowMonitorState |
Stream was created, but no events have passed through it
|
FlowMonitorState.Failed |
Stream failed
|
FlowMonitorState.Failed$ |
|
FlowMonitorState.Finished$ |
Stream completed successfully
|
FlowMonitorState.Initialized$ |
|
FlowMonitorState.Received<U> |
Stream processed a message
|
FlowMonitorState.Received$ |
|
FlowMonitorState$ |
Stream was created, but no events have passed through it
|
FlowShape<I,O> |
A Flow Shape has exactly one input and one output, it looks from the
outside like a pipe (but it can be a complex topology of streams within of
course).
|
FlowShape$ |
Java API
|
GraphDelegate<S extends Shape,Mat> |
INTERNAL API
|
IgnoreBoth |
|
IgnoreBoth$ |
|
IgnoreCancel |
|
IgnoreCancel$ |
|
IgnoreComplete |
|
IgnoreComplete$ |
|
Inlet<T> |
INTERNAL API.
|
Inlet$ |
Scala API
|
InPort |
INTERNAL API
|
InvalidPartnerActorException$ |
|
InvalidSequenceNumberException$ |
|
IOResult |
Java API: Numeric value depending on context, for example IO operations performed or bytes processed.
|
IOResult$ |
JAVA API: Creates successful IOResult
|
IOSettings |
Java API
|
IOSettings$ |
Java API
|
KillSwitches |
Creates a new SharedKillSwitch with the given name that can be used to control the completion of multiple
streams from the outside simultaneously.
|
KillSwitches.KillableGraphStageLogic |
|
KillSwitches.UniqueBidiKillSwitchStage$ |
|
KillSwitches.UniqueKillSwitchStage$ |
|
KillSwitches$ |
Creates a new SharedKillSwitch with the given name that can be used to control the completion of multiple
streams from the outside simultaneously.
|
MaterializationContext |
Context parameter to the create methods of sources and sinks.
|
MaterializationContext$ |
|
MaterializationException$ |
|
Materializer |
The namePrefix shall be used for deriving the names of processing
entities that are created during materialization.
|
Materializer$ |
Implicitly provides the system wide materializer from a classic or typed ActorSystem
|
NoMaterializer |
INTERNAL API
|
NoMaterializer$ |
INTERNAL API
|
Outlet<T> |
INTERNAL API.
|
Outlet$ |
Scala API
|
OutPort |
INTERNAL API
|
OverflowStrategies |
INTERNAL API
|
OverflowStrategies.Backpressure |
|
OverflowStrategies.Backpressure$ |
|
OverflowStrategies.DropBuffer |
|
OverflowStrategies.DropBuffer$ |
|
OverflowStrategies.DropHead |
|
OverflowStrategies.DropHead$ |
|
OverflowStrategies.DropNew |
|
OverflowStrategies.DropNew$ |
|
OverflowStrategies.DropTail |
|
OverflowStrategies.DropTail$ |
|
OverflowStrategies.EmitEarly$ |
|
OverflowStrategies.Fail |
|
OverflowStrategies.Fail$ |
|
OverflowStrategies$ |
INTERNAL API
|
OverflowStrategy |
INTERNAL API
|
OverflowStrategy$ |
If the buffer is full when a new element arrives, drops the oldest element from the buffer to make space for
the new element.
|
QueueOfferResult |
|
QueueOfferResult.Dropped$ |
Type is used to indicate that stream is dropped an element
|
QueueOfferResult.Enqueued$ |
|
QueueOfferResult.Failure |
Type is used to indicate that stream is failed before or during call to the stream
param: cause - exception that stream failed with
|
QueueOfferResult.Failure$ |
|
QueueOfferResult.QueueClosed$ |
|
QueueOfferResult$ |
Type is used to indicate that stream is successfully enqueued an element
|
RemoteStreamRefActorTerminatedException$ |
|
Server |
The server is usually the side the provides the service to its interlocutor.
|
Server$ |
|
Shape |
Scala API: get a list of all input ports
|
Shape$ |
inlets and outlets can be Vector or List so this method
checks the size of 1 in an optimized way.
|
SharedKillSwitch |
After calling SharedKillSwitch.shutdown() all materialized, running instances of all Graph s provided by the
SharedKillSwitch will complete their downstreams and cancel their upstreams (unless if finished or failed already in which
case the command is ignored).
|
SinkRef$ |
Implicitly converts a SinkRef to a Sink .
|
SinkShape<T> |
A Sink Shape has exactly one input and no outputs, it models a data sink.
|
SinkShape$ |
Java API
|
SourceRef$ |
Implicitly converts a SourceRef to a Source.
|
SourceShape<T> |
A Source Shape has exactly one output and no inputs, it models a source
of data.
|
SourceShape$ |
Java API
|
StreamRefAttributes |
Attributes specific to stream refs.
|
StreamRefAttributes.SubscriptionTimeout |
|
StreamRefAttributes.SubscriptionTimeout$ |
|
StreamRefAttributes$ |
Attributes specific to stream refs.
|
StreamRefMessages |
|
StreamRefMessages.ActorRef |
Protobuf type ActorRef
|
StreamRefMessages.ActorRef.Builder |
Protobuf type ActorRef
|
StreamRefMessages.CumulativeDemand |
Protobuf type CumulativeDemand
|
StreamRefMessages.CumulativeDemand.Builder |
Protobuf type CumulativeDemand
|
StreamRefMessages.OnSubscribeHandshake |
Protobuf type OnSubscribeHandshake
|
StreamRefMessages.OnSubscribeHandshake.Builder |
Protobuf type OnSubscribeHandshake
|
StreamRefMessages.Payload |
Protobuf type Payload
|
StreamRefMessages.Payload.Builder |
Protobuf type Payload
|
StreamRefMessages.RemoteStreamCompleted |
Protobuf type RemoteStreamCompleted
|
StreamRefMessages.RemoteStreamCompleted.Builder |
Protobuf type RemoteStreamCompleted
|
StreamRefMessages.RemoteStreamFailure |
Protobuf type RemoteStreamFailure
|
StreamRefMessages.RemoteStreamFailure.Builder |
Protobuf type RemoteStreamFailure
|
StreamRefMessages.SequencedOnNext |
Protobuf type SequencedOnNext
|
StreamRefMessages.SequencedOnNext.Builder |
Protobuf type SequencedOnNext
|
StreamRefMessages.SinkRef |
Protobuf type SinkRef
|
StreamRefMessages.SinkRef.Builder |
Protobuf type SinkRef
|
StreamRefMessages.SourceRef |
Protobuf type SourceRef
|
StreamRefMessages.SourceRef.Builder |
Protobuf type SourceRef
|
StreamRefResolver$ |
Java API
|
StreamRefSettings$ |
Java API
|
StreamRefSubscriptionTimeoutException$ |
|
StreamSubscriptionTimeoutSettings |
|
StreamSubscriptionTimeoutSettings$ |
Create settings from individual values (Java).
|
StreamSubscriptionTimeoutTerminationMode |
This mode describes what shall happen when the subscription timeout expires for
substream Publishers created by operations like prefixAndTail .
|
StreamSubscriptionTimeoutTerminationMode.CancelTermination$ |
|
StreamSubscriptionTimeoutTerminationMode.NoopTermination$ |
|
StreamSubscriptionTimeoutTerminationMode.WarnTermination$ |
|
StreamSubscriptionTimeoutTerminationMode$ |
Do not do anything when timeout expires.
|
SubscriptionWithCancelException |
Not for user extension
|
SubscriptionWithCancelException$ |
Not for user extension
|
SubstreamCancelStrategies |
INTERNAL API
|
SubstreamCancelStrategies.Drain$ |
|
SubstreamCancelStrategies.Propagate$ |
|
SubstreamCancelStrategies$ |
INTERNAL API
|
SubstreamCancelStrategy |
Represents a strategy that decides how to deal with substream events.
|
SubstreamCancelStrategy$ |
Cancel the stream of streams if any substream is cancelled.
|
Supervision |
Scala API: The stream will be completed with failure if application code for processing an element
throws an exception.
|
Supervision.Restart$ |
Scala API: The element is dropped and the stream continues after restarting the operator
if application code for processing an element throws an exception.
|
Supervision.Resume$ |
Scala API: The element is dropped and the stream continues if application code for processing
an element throws an exception.
|
Supervision.Stop$ |
|
Supervision$ |
Scala API: The stream will be completed with failure if application code for processing an element
throws an exception.
|
SystemMaterializer |
|
SystemMaterializer$ |
The system materializer is a default materializer to use for most cases running streams, it is a single instance
per actor system that is tied to the lifecycle of that system.
|
TargetRefNotInitializedYetException$ |
|
TerminationSignal |
After calling KillSwitch#abort() the linked Graph s of FlowShape are failed.
|
ThrottleMode |
Represents a mode that decides how to deal exceed rate for Throttle operator
|
ThrottleMode.Enforcing$ |
|
ThrottleMode.Shaping$ |
|
ThrottleMode$ |
Tells throttle to make pauses before emitting messages to meet throttle rate
|
TLSClientAuth |
An SSLEngine can either demand, allow or ignore its peer’s authentication
(via certificates), where Need will fail the handshake if the peer does
not provide valid credentials, Want allows the peer to send credentials
and verifies them if provided, and None disables peer certificate
verification.
|
TLSClientAuth.Need$ |
|
TLSClientAuth.None$ |
|
TLSClientAuth.Want$ |
|
TLSClientAuth$ |
|
TLSClosing |
All streams in Akka are unidirectional: while in a complex flow graph data
may flow in multiple directions these individual flows are independent from
each other.
|
TLSClosing$ |
|
TLSProtocol |
This is the supertype of all messages that the SslTls operator emits on the
plaintext side.
|
TLSProtocol.NegotiateNewSession |
|
TLSProtocol.NegotiateNewSession$ |
|
TLSProtocol.SendBytes |
Send the given ByteString across the encrypted session to the
peer.
|
TLSProtocol.SendBytes$ |
|
TLSProtocol.SessionBytes |
|
TLSProtocol.SessionBytes$ |
|
TLSProtocol.SessionTruncated |
|
TLSProtocol.SessionTruncated$ |
|
TLSProtocol$ |
This is the supertype of all messages that the SslTls operator emits on the
plaintext side.
|
TLSRole |
Java API: obtain the Server singleton value.
|
TLSRole$ |
Java API: obtain the Client singleton value.
|
UniformFanInShape<T,O> |
|
UniformFanInShape$ |
|
UniformFanOutShape<I,O> |
|
UniformFanOutShape$ |
|
UniqueKillSwitch |
|