Packages

package impl

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. 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.

  2. 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.

  3. final class ActorRefSink [In] extends SinkModule[In, NotUsed]

    INTERNAL API

  4. final class ActorRefSource [Out] extends SourceModule[Out, ActorRef]

    INTERNAL API

  5. 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.

  6. final class CancelSink extends SinkModule[Any, NotUsed]

    INTERNAL API A sink that immediately cancels its upstream upon materialization.

  7. abstract class ExtendedActorMaterializer extends ActorMaterializer

    ExtendedActorMaterializer used by subtypes which materializer using GraphInterpreterShell

  8. abstract class FanIn extends Actor with ActorLogging with Pump

    INTERNAL API

  9. abstract class FanOut extends Actor with ActorLogging with Pump

    INTERNAL API

  10. class FlowNames extends Extension

    INTERNAL API

  11. final class HeadOptionStage [T] extends GraphStageWithMaterializedValue[SinkShape[T], Future[Option[T]]]
  12. final class LastOptionStage [T] extends GraphStageWithMaterializedValue[SinkShape[T], Future[Option[T]]]
  13. abstract class MaterializerSession extends AnyRef

    INTERNAL API

  14. final class MaybeSource [Out] extends SourceModule[Out, Promise[Option[Out]]]

    INTERNAL API

  15. final case class ProcessorModule [In, Out, Mat](createProcessor: () ⇒ (Processor[In, Out], Mat), attributes: Attributes = DefaultAttributes.processor) extends AtomicModule with Product with Serializable

    INTERNAL API

  16. 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.

  17. final class QueueSink [T] extends GraphStageWithMaterializedValue[SinkShape[T], SinkQueueWithCancel[T]]

    INTERNAL API

  18. 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

  19. final class SeqStage [T] extends GraphStageWithMaterializedValue[SinkShape[T], Future[Seq[T]]]
  20. abstract class SinkModule [-In, Mat] extends AtomicModule

    INTERNAL API

  21. final class SinkQueueAdapter [T] extends SinkQueueWithCancel[T]
  22. abstract class SourceModule [+Out, +Mat] extends AtomicModule

    INTERNAL API

  23. class StreamSupervisor extends Actor
  24. class SubFlowImpl [In, Out, Mat, F[+_], C] extends SubFlow[Out, Mat, F, C]
  25. final class SubscriberSink [In] extends SinkModule[In, NotUsed]

    INTERNAL API Attaches a subscriber to this stream.

  26. 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. The Subscriber can later be connected to an upstream Publisher.

  27. class Throttle [T] extends SimpleLinearGraphStage[T]

    INTERNAL API

  28. final class Unfold [S, E] extends GraphStage[SourceShape[E]]

    INTERNAL API

  29. final class UnfoldAsync [S, E] extends GraphStage[SourceShape[E]]

    INTERNAL API

Value Members

  1. object ActorPublisher

    INTERNAL API

  2. object FanIn

    INTERNAL API

  3. object FanOut

    INTERNAL API

  4. object FlowNames extends ExtensionId[FlowNames] with ExtensionIdProvider

    INTERNAL API

  5. object MaterializerSession

    INERNAL API

  6. object SeqActorName
  7. object Stages

    INTERNAL API

  8. object StreamLayout

    INTERNAL API

  9. object StreamSubscriptionTimeoutSupport
  10. object StreamSupervisor

    INTERNAL API

  11. object SubFlowImpl
  12. 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

Ungrouped