| Interface | Description |
|---|---|
| Attributes.Attribute | |
| FanInShape.Init<O> | |
| FanOutShape.Init<I> | |
| FlowMonitor<T> |
Used to monitor the state of a stream
|
| FlowMonitorState.StreamState<U> | |
| Graph<S extends Shape,M> | |
| KillSwitch |
A
KillSwitch allows completion of Graphs from the outside by completing Graphs of FlowShape linked
to the switch. |
| MaterializerLoggingProvider |
SPI intended only to be extended by custom
Materializer implementations,
that also want to provide stages they materialize with specialized LoggingAdapter instances. |
| Supervision.Directive | |
| TLSProtocol.SslTlsInbound |
This is the supertype of all messages that the SslTls stage emits on the
plaintext side.
|
| TLSProtocol.SslTlsOutbound |
This is the supertype of all messages that the SslTls stage accepts on its
plaintext side.
|
| Class | Description |
|---|---|
| AbruptTerminationException$ | |
| AbstractShape |
Java API for creating custom
Shape types. |
| ActorAttributes |
Attributes for the
ActorMaterializer. |
| ActorAttributes.Dispatcher | |
| ActorAttributes.Dispatcher$ | |
| ActorAttributes.SupervisionStrategy | |
| ActorAttributes.SupervisionStrategy$ | |
| ActorAttributes$ |
Attributes for the
ActorMaterializer. |
| ActorMaterializer |
An ActorMaterializer takes the list of transformations comprising a
Flow and materializes them in the form of
Processor instances. |
| ActorMaterializer$ | |
| ActorMaterializerHelper |
INTERNAL API
|
| ActorMaterializerHelper$ |
INTERNAL API
|
| ActorMaterializerSettings |
This class describes the configurable properties of the
ActorMaterializer. |
| 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 | |
| Attributes.AsyncBoundary$ | |
| Attributes.InputBuffer | |
| Attributes.InputBuffer$ | |
| Attributes.LogLevels | |
| Attributes.LogLevels$ | |
| Attributes.Name | |
| Attributes.Name$ | |
| Attributes$ |
Note that more attributes for the
ActorMaterializer are defined in ActorAttributes. |
| BidiShape<In1,Out1,In2,Out2> |
A bidirectional flow of elements that consequently has two inputs and two
outputs, arranged like this:
|
| BidiShape$ | |
| 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$ | |
| DelayOverflowStrategy |
Represents a strategy that decides how to deal with a buffer of time based stage
that is full but is about to receive a new element.
|
| DelayOverflowStrategy$ | |
| EagerClose |
see
TLSClosing |
| EagerClose$ | |
| FanInShape<O> | |
| 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> | |
| 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> | |
| 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 | |
| FlowMonitorState.Failed |
Stream failed
|
| FlowMonitorState.Failed$ | |
| FlowMonitorState.Finished$ |
Stream completed successfully
|
| FlowMonitorState.Initialized$ |
Stream was created, but no events have passed through it
|
| FlowMonitorState.Received<U> |
Stream processed a message
|
| FlowMonitorState.Received$ | |
| FlowMonitorState$ | |
| 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$ | |
| Fusing |
This class holds some graph transformation functions that can fuse together
multiple operation stages into synchronous execution islands.
|
| Fusing.FusedGraph<S extends Shape,M> |
A fused graph of the right shape, containing a
FusedModule which
holds more information on the operation structure of the contained stream
topology for convenient graph traversal. |
| Fusing.FusedGraph$ | |
| Fusing$ |
This class holds some graph transformation functions that can fuse together
multiple operation stages into synchronous execution islands.
|
| IgnoreBoth |
see
TLSClosing |
| IgnoreBoth$ | |
| IgnoreCancel |
see
TLSClosing |
| IgnoreCancel$ | |
| IgnoreComplete |
see
TLSClosing |
| IgnoreComplete$ | |
| Inlet<T> | |
| Inlet$ |
An Inlet is a typed input to a Shape.
|
| InPort |
An input port of a StreamLayout.Module.
|
| IOResult |
Holds a result of an IO operation.
|
| IOResult$ | |
| KillSwitches |
Creates shared or single kill switches which can be used to control completion of graphs from the outside.
|
| KillSwitches.KillableGraphStageLogic | |
| KillSwitches.UniqueBidiKillSwitchStage$ | |
| KillSwitches.UniqueKillSwitchStage$ | |
| KillSwitches$ |
Creates shared or single kill switches which can be used to control completion of graphs from the outside.
|
| MaterializationContext |
Context parameter to the
create methods of sources and sinks. |
| MaterializationContext$ | |
| MaterializationException$ | |
| Materializer |
Materializer SPI (Service Provider Interface)
|
| NoMaterializer |
INTERNAL API
|
| NoMaterializer$ |
INTERNAL API
|
| Outlet<T> | |
| Outlet$ |
An Outlet is a typed output to a Shape.
|
| OutPort |
An output port of a StreamLayout.Module.
|
| OverflowStrategies | |
| OverflowStrategies.Backpressure$ |
INTERNAL API
|
| OverflowStrategies.DropBuffer$ |
INTERNAL API
|
| OverflowStrategies.DropHead$ |
INTERNAL API
|
| OverflowStrategies.DropNew$ |
INTERNAL API
|
| OverflowStrategies.DropTail$ |
INTERNAL API
|
| OverflowStrategies.EmitEarly$ |
INTERNAL API
|
| OverflowStrategies.Fail$ |
INTERNAL API
|
| OverflowStrategies$ | |
| OverflowStrategy |
Represents a strategy that decides how to deal with a buffer that is full but is
about to receive a new element.
|
| OverflowStrategy$ | |
| QueueOfferResult | |
| QueueOfferResult.Dropped$ |
Type is used to indicate that stream is dropped an element
|
| QueueOfferResult.Enqueued$ |
Type is used to indicate that stream is successfully enqueued an element
|
| 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$ |
Type is used to indicate that stream is completed before call
|
| QueueOfferResult$ |
Contains types that is used as return types for async callbacks to streams
|
| Server |
The server is usually the side the provides the service to its interlocutor.
|
| Server$ | |
| Shape |
A Shape describes the inlets and outlets of a
Graph. |
| SharedKillSwitch |
A
SharedKillSwitch is a provider for Graphs of FlowShape that can be completed or failed from the outside. |
| SinkShape<T> |
A Sink
Shape has exactly one input and no outputs, it models a data sink. |
| SinkShape$ | |
| SourceShape<T> |
A Source
Shape has exactly one output and no inputs, it models a source
of data. |
| SourceShape$ | |
| StreamSubscriptionTimeoutSettings |
Leaked publishers and subscribers are cleaned up when they are not used within a given
deadline, configured by
StreamSubscriptionTimeoutSettings. |
| StreamSubscriptionTimeoutSettings$ | |
| 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$ | |
| SubstreamCancelStrategies | |
| SubstreamCancelStrategies.Drain$ |
INTERNAL API
|
| SubstreamCancelStrategies.Propagate$ |
INTERNAL API
|
| SubstreamCancelStrategies$ | |
| SubstreamCancelStrategy |
Represents a strategy that decides how to deal with substream events.
|
| SubstreamCancelStrategy$ | |
| Supervision | |
| Supervision.Restart$ |
Scala API: The element is dropped and the stream continues after restarting the stage
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$ |
Scala API: The stream will be completed with failure if application code for processing an element
throws an exception.
|
| Supervision$ | |
| ThrottleMode |
Represents a mode that decides how to deal exceed rate for Throttle combinator
|
| ThrottleMode.Enforcing$ |
Makes throttle fail with exception when upstream is faster than throttle rate
|
| ThrottleMode.Shaping$ |
Tells throttle to make pauses before emitting messages to meet throttle rate
|
| ThrottleMode$ | |
| 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 | |
| TLSProtocol.NegotiateNewSession |
Initiate a new session negotiation.
|
| TLSProtocol.NegotiateNewSession$ | |
| TLSProtocol.SendBytes |
Send the given
ByteString across the encrypted session to the
peer. |
| TLSProtocol.SendBytes$ | |
| TLSProtocol.SessionBytes |
Plaintext bytes emitted by the SSLEngine are received over one specific
encryption session and this class bundles the bytes with the SSLSession
object.
|
| TLSProtocol.SessionBytes$ | |
| TLSProtocol.SessionTruncated |
If the underlying transport is closed before the final TLS closure command
is received from the peer then the SSLEngine will throw an SSLException that
warns about possible truncation attacks.
|
| TLSProtocol.SessionTruncated$ | |
| TLSProtocol$ | |
| TLSRole | |
| TLSRole$ |
Many protocols are asymmetric and distinguish between the client and the
server, where the latter listens passively for messages and the former
actively initiates the exchange.
|
| TransformerLike<T,U> | |
| UniformFanInShape<T,O> | |
| UniformFanInShape$ | |
| UniformFanOutShape<I,O> | |
| UniformFanOutShape$ | |
| UniqueKillSwitch |
A
UniqueKillSwitch is always a result of a materialization (unlike SharedKillSwitch which is constructed
before any materialization) and it always controls that graph and stage which yielded the materialized value. |
| Exception | Description |
|---|---|
| AbruptStageTerminationException |
Signal that the stage was abruptly terminated, usually seen as a call to
postStop of the GraphStageLogic without
any of the handler callbacks seeing completion or failure from upstream or cancellation from downstream. |
| AbruptTerminationException |
This exception signals that an actor implementing a Reactive Streams Subscriber, Publisher or Processor
has been terminated without being notified by an onError, onComplete or cancel signal.
|
| BindFailedException | |
| BindFailedException$ | Deprecated
BindFailedException object will never be thrown.
|
| BufferOverflowException | |
| ConnectionException | |
| MaterializationException |
This exception or subtypes thereof should be used to signal materialization
failures.
|
| RateExceededException |
Exception that is thrown when rated controlled by stream is exceeded
|
| StreamLimitReachedException | |
| StreamTcpException |