| AbruptIOTerminationException$ |
|
| AbruptTerminationException$ |
|
| AbstractShape |
Java API for creating custom Shape types. |
| ActorAttributes |
|
| ActorAttributes.DebugLogging |
Enables additional low level troubleshooting logging at DEBUG log level
|
| ActorAttributes.DebugLogging$ |
|
| ActorAttributes.Dispatcher |
Configures the dispatcher to be used by streams.
|
| ActorAttributes.Dispatcher$ |
|
| ActorAttributes.FuzzingMode |
Test utility: fuzzing mode means that GraphStage events are not processed
in FIFO order within a fused subgraph, but randomized.
|
| ActorAttributes.FuzzingMode$ |
|
| ActorAttributes.MaxFixedBufferSize |
Configure the maximum buffer size for which a FixedSizeBuffer will be preallocated.
|
| ActorAttributes.MaxFixedBufferSize$ |
|
| ActorAttributes.OutputBurstLimit |
Maximum number of elements emitted in batch if downstream signals large demand.
|
| ActorAttributes.OutputBurstLimit$ |
|
| ActorAttributes.StreamSubscriptionTimeout |
Defines a timeout for stream subscription and what action to take when that hits.
|
| ActorAttributes.StreamSubscriptionTimeout$ |
|
| ActorAttributes.SupervisionStrategy |
|
| ActorAttributes.SupervisionStrategy$ |
|
| ActorAttributes.SyncProcessingLimit |
Limit for number of messages that can be processed synchronously in stream to substream communication.
|
| ActorAttributes.SyncProcessingLimit$ |
|
| ActorAttributes$ |
|
| ActorMaterializer |
Deprecated.
|
| ActorMaterializer$ |
|
| ActorMaterializerHelper |
INTERNAL API
|
| ActorMaterializerHelper$ |
INTERNAL API
|
| ActorMaterializerSettings |
|
| 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 |
Holds attributes which can be used to alter pekko.stream.scaladsl.Flow / pekko.stream.javadsl.Flow
or pekko.stream.scaladsl.GraphDSL / pekko.stream.javadsl.GraphDSL materialization.
|
| Attributes.AsyncBoundary$ |
|
| Attributes.CancellationStrategy |
Cancellation strategies provide a way to configure the behavior of a stage when cancelStage is called.
|
| Attributes.CancellationStrategy$ |
|
| Attributes.CancellationStrategy$.AfterDelay |
Strategy that allows to delay any action when cancelStage is invoked.
|
| Attributes.CancellationStrategy$.AfterDelay$ |
|
| Attributes.CancellationStrategy$.CompleteStage$ |
Strategy that treats cancelStage the same as completeStage, i.e.
|
| Attributes.CancellationStrategy$.FailStage$ |
Strategy that treats cancelStage the same as failStage, i.e.
|
| Attributes.CancellationStrategy$.PropagateFailure$ |
Strategy that treats cancelStage in different ways depending on the cause that was given to the cancellation.
|
| Attributes.InputBuffer |
Each asynchronous piece of a materialized stream topology is executed by one Actor
that manages an input buffer for all inlets of its shape.
|
| Attributes.InputBuffer$ |
|
| Attributes.LogLevels |
|
| Attributes.LogLevels$ |
|
| Attributes.Name |
|
| Attributes.Name$ |
|
| Attributes.NestedMaterializationCancellationPolicy |
Nested materialization cancellation strategy provides a way to configure the cancellation behavior of stages that materialize a nested flow.
|
| Attributes.NestedMaterializationCancellationPolicy$ |
|
| Attributes.SourceLocation |
Attribute that contains the source location of for example a lambda passed to an operator, useful for example
for debugging.
|
| Attributes.SourceLocation$ |
|
| Attributes$ |
|
| 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$ |
|
| CompletionStrategy.Draining$ |
INTERNAL API
|
| CompletionStrategy.Immediately$ |
INTERNAL API
|
| CompletionStrategy$ |
|
| DelayOverflowStrategy |
Represents a strategy that decides how to deal with a buffer of time based operator
that is full but is about to receive a new element.
|
| DelayOverflowStrategy$ |
|
| EagerClose |
|
| 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> |
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> |
|
| 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$ |
|
| Graph.GraphMapMatVal<S extends Shape,M> |
Scala API, see https://github.com/akka/akka/issues/28501 for discussion why this can't be an instance method on class Graph.
|
| Graph$ |
|
| IgnoreBoth |
|
| IgnoreBoth$ |
|
| IgnoreCancel |
|
| IgnoreCancel$ |
|
| IgnoreComplete |
|
| IgnoreComplete$ |
|
| Inlet<T> |
|
| Inlet$ |
An Inlet is a typed input to a Shape.
|
| InPort |
An input port of a StreamLayout.Module.
|
| InvalidPartnerActorException$ |
|
| InvalidSequenceNumberException$ |
|
| IOResult |
Holds a result of an IO operation.
|
| IOResult$ |
|
| IOSettings |
|
| IOSettings$ |
|
| 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$ |
|
| MaterializationException$ |
|
| Materializer |
The Materializer is the component responsible for turning a stream blueprint into a running stream.
|
| Materializer$ |
|
| Outlet<T> |
|
| Outlet$ |
An Outlet is a typed output to a Shape.
|
| OutPort |
An output port of a StreamLayout.Module.
|
| OverflowStrategies |
|
| OverflowStrategies.Backpressure$ |
|
| OverflowStrategies.DropBuffer$ |
|
| OverflowStrategies.DropHead$ |
|
| OverflowStrategies.DropNew$ |
|
| OverflowStrategies.DropTail$ |
|
| OverflowStrategies.EmitEarly$ |
INTERNAL API
|
| OverflowStrategies.Fail$ |
|
| 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$ |
|
| QueueCompletionResult |
Not for user extension
|
| QueueOfferResult |
Not for user extension
|
| 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 streams Source queues
|
| RemoteStreamRefActorTerminatedException$ |
|
| RestartSettings |
|
| RestartSettings.LogSettings |
|
| RestartSettings.LogSettings$ |
|
| RestartSettings$ |
|
| 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. |
| Shape$ |
INTERNAL API
|
| SharedKillSwitch |
|
| SinkRef$ |
|
| SinkShape<T> |
A Sink Shape has exactly one input and no outputs, it models a data sink. |
| SinkShape$ |
|
| SourceRef$ |
|
| SourceShape<T> |
A Source Shape has exactly one output and no inputs, it models a source
of data. |
| SourceShape$ |
|
| StreamRefAttributes |
Attributes for stream refs (pekko.stream.SourceRef and pekko.stream.SinkRef).
|
| StreamRefAttributes.BufferCapacity |
|
| StreamRefAttributes.BufferCapacity$ |
|
| StreamRefAttributes.DemandRedeliveryInterval |
|
| StreamRefAttributes.DemandRedeliveryInterval$ |
|
| StreamRefAttributes.FinalTerminationSignalDeadline |
|
| StreamRefAttributes.FinalTerminationSignalDeadline$ |
|
| StreamRefAttributes.SubscriptionTimeout |
|
| StreamRefAttributes.SubscriptionTimeout$ |
|
| StreamRefAttributes$ |
Attributes for stream refs (pekko.stream.SourceRef and pekko.stream.SinkRef).
|
| 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$ |
The stream ref resolver extension provides a way to serialize and deserialize streamrefs in user serializers.
|
| StreamRefSettings$ |
|
| StreamRefSubscriptionTimeoutException$ |
|
| 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$ |
|
| SubscriptionWithCancelException$ |
|
| 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 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$ |
Scala API: The stream will be completed with failure if application code for processing an element
throws an exception.
|
| Supervision$ |
|
| 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$ |
|
| ThrottleMode |
Represents a mode that decides how to deal exceed rate for Throttle operator
|
| 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 Pekko 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 pekko.util.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.
|
| 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 operator which yielded the materialized value. |