package impl
- Alphabetic
- Public
- All
Type Members
-
class
ActorPublisher
[T] extends Publisher[T]
INTERNAL API
INTERNAL API
When you instantiate this class, or its subclasses, you MUST send an ExposedPublisher message to the wrapped ActorRef! If you don't need to subclass, prefer the apply() method on the companion object which takes care of this.
-
final
class
ActorPublisherSource
[Out] extends SourceModule[Out, ActorRef]
INTERNAL API Creates and wraps an actor into org.reactivestreams.Publisher from the given
props
, which should be akka.actor.Props for an akka.stream.actor.ActorPublisher. -
final
class
ActorRefSink
[In] extends SinkModule[In, NotUsed]
INTERNAL API
-
final
class
ActorRefSource
[Out] extends SourceModule[Out, ActorRef]
INTERNAL API
-
final
class
ActorSubscriberSink
[In] extends SinkModule[In, ActorRef]
INTERNAL API Creates and wraps an actor into org.reactivestreams.Subscriber from the given
props
, which should be akka.actor.Props for an akka.stream.actor.ActorSubscriber. -
final
class
CancelSink
extends SinkModule[Any, NotUsed]
INTERNAL API A sink that immediately cancels its upstream upon materialization.
-
abstract
class
ExtendedActorMaterializer
extends ActorMaterializer
ExtendedActorMaterializer used by subtypes which materializer using GraphInterpreterShell
-
abstract
class
FanIn
extends Actor with ActorLogging with Pump
INTERNAL API
-
abstract
class
FanOut
extends Actor with ActorLogging with Pump
INTERNAL API
-
class
FlowNames
extends Extension
INTERNAL API
- final class HeadOptionStage [T] extends GraphStageWithMaterializedValue[SinkShape[T], Future[Option[T]]]
- final class LastOptionStage [T] extends GraphStageWithMaterializedValue[SinkShape[T], Future[Option[T]]]
-
abstract
class
MaterializerSession
extends AnyRef
INTERNAL API
-
final
class
MaybeSource
[Out] extends SourceModule[Out, Promise[Option[Out]]]
INTERNAL API
-
final
case class
ProcessorModule
[In, Out, Mat](createProcessor: () ⇒ (Processor[In, Out], Mat), attributes: Attributes = DefaultAttributes.processor) extends AtomicModule with Product with Serializable
INTERNAL API
-
final
class
PublisherSource
[Out] extends SourceModule[Out, NotUsed]
INTERNAL API Construct a transformation starting with given publisher.
INTERNAL API Construct a transformation starting with given publisher. The transformation steps are executed by a series of org.reactivestreams.Processor instances that mediate the flow of elements downstream and the propagation of back-pressure upstream.
-
final
class
QueueSink
[T] extends GraphStageWithMaterializedValue[SinkShape[T], SinkQueueWithCancel[T]]
INTERNAL API
-
abstract
class
SeqActorName
extends AnyRef
INTERNAL API As discussed in https://github.com/akka/akka/issues/16613
INTERNAL API As discussed in https://github.com/akka/akka/issues/16613
Generator of sequentially numbered actor names. Pulled out from HTTP internals, most often used used by streams which materialize actors directly
- final class SeqStage [T] extends GraphStageWithMaterializedValue[SinkShape[T], Future[Seq[T]]]
-
abstract
class
SinkModule
[-In, Mat] extends AtomicModule
INTERNAL API
- final class SinkQueueAdapter [T] extends SinkQueueWithCancel[T]
-
abstract
class
SourceModule
[+Out, +Mat] extends AtomicModule
INTERNAL API
- class StreamSupervisor extends Actor
- class SubFlowImpl [In, Out, Mat, F[+_], C] extends SubFlow[Out, Mat, F, C]
-
final
class
SubscriberSink
[In] extends SinkModule[In, NotUsed]
INTERNAL API Attaches a subscriber to this stream.
-
final
class
SubscriberSource
[Out] extends SourceModule[Out, Subscriber[Out]]
INTERNAL API Holds a
Subscriber
representing the input side of the flow.INTERNAL API Holds a
Subscriber
representing the input side of the flow. TheSubscriber
can later be connected to an upstreamPublisher
. -
class
Throttle
[T] extends SimpleLinearGraphStage[T]
INTERNAL API
-
final
class
Unfold
[S, E] extends GraphStage[SourceShape[E]]
INTERNAL API
-
final
class
UnfoldAsync
[S, E] extends GraphStage[SourceShape[E]]
INTERNAL API
Value Members
-
object
ActorPublisher
INTERNAL API
-
object
FanIn
INTERNAL API
-
object
FanOut
INTERNAL API
-
object
FlowNames
extends ExtensionId[FlowNames] with ExtensionIdProvider
INTERNAL API
-
object
MaterializerSession
INERNAL API
- object SeqActorName
-
object
Stages
INTERNAL API
-
object
StreamLayout
INTERNAL API
- object StreamSubscriptionTimeoutSupport
-
object
StreamSupervisor
INTERNAL API
- object SubFlowImpl
-
object
Timers
INTERNAL API
INTERNAL API
Various stages for controlling timeouts on IO related streams (although not necessarily).
The common theme among the processing stages here that
- they wait for certain event or events to happen
- they have a timer that may fire before these events
- if the timer fires before the event happens, these stages all fail the stream
- otherwise, these streams do not interfere with the element flow, ordinary completion or failure