akka.stream

actor

package actor

Content Hierarchy Learn more about scaladoc diagrams
Visibility
  1. Public
  2. All

Type Members

  1. abstract class AbstractActorPublisher[T] extends AbstractActor with ActorPublisher[T]

    Java API compatible with lambda expressions

  2. abstract class AbstractActorSubscriber extends AbstractActor with ActorSubscriber

    Java API compatible with lambda expressions

  3. trait ActorPublisher[T] extends Actor

    Extend/mixin this trait in your akka.actor.Actor to make it a stream publisher that keeps track of the subscription life cycle and requested elements.

  4. sealed abstract class ActorPublisherMessage extends DeadLetterSuppression

  5. trait ActorSubscriber extends Actor

    Extend/mixin this trait in your akka.actor.Actor to make it a stream subscriber with full control of stream back pressure.

  6. sealed abstract class ActorSubscriberMessage extends DeadLetterSuppression with NoSerializationVerificationNeeded

  7. abstract class MaxInFlightRequestStrategy extends RequestStrategy

    Requests up to the max and also takes the number of messages that have been queued internally or delegated to other actors into account.

  8. trait RequestStrategy extends AnyRef

    An ActorSubscriber defines a RequestStrategy to control the stream back pressure.

  9. abstract class UntypedActorPublisher[T] extends UntypedActor with ActorPublisher[T]

    Java API

  10. abstract class UntypedActorSubscriber extends UntypedActor with ActorSubscriber

    Java API

  11. final case class WatermarkRequestStrategy(highWatermark: Int, lowWatermark: Int) extends RequestStrategy with Product with Serializable

    Requests up to the highWatermark when the remainingRequested is below the lowWatermark.

Value Members

  1. object AbstractActorPublisher

    Java API compatible with lambda expressions

  2. object AbstractActorSubscriber

    Java API compatible with lambda expressions

  3. object ActorPublisher

  4. object ActorPublisherMessage

  5. object ActorSubscriber

  6. object ActorSubscriberMessage

  7. object OneByOneRequestStrategy extends RequestStrategy with Product with Serializable

    Requests one more element when remainingRequested is 0, i.

  8. object UntypedActorPublisher

    Java API

  9. object UntypedActorSubscriber

    Java API

  10. object WatermarkRequestStrategy extends Serializable

  11. object ZeroRequestStrategy extends RequestStrategy with Product with Serializable

    When request is only controlled with manual calls to ActorSubscriber#request.

Ungrouped