Packages

object ActorSink

Collection of Sinks aimed at integrating with typed Actors.

Source
ActorSink.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ActorSink
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. def actorRef[T](ref: ActorRef[T], onCompleteMessage: T, onFailureMessage: (Throwable) => T): Sink[T, NotUsed]

    Sends the elements of the stream to the given ActorRef.

    Sends the elements of the stream to the given ActorRef. If the target actor terminates the stream will be canceled. When the stream is completed successfully the given onCompleteMessage will be sent to the destination actor. When the stream is completed with failure a the throwable that was signaled to the stream is adapted to the Actors protocol using onFailureMessage and then then sent to the destination actor.

    It will request at most maxInputBufferSize number of elements from upstream, but there is no back-pressure signal from the destination actor, i.e. if the actor is not consuming the messages fast enough the mailbox of the actor will grow. For potentially slow consumer actors it is recommended to use a bounded mailbox with zero mailbox-push-timeout-time or use a rate limiting stage in front of this Sink.

  5. def actorRefWithBackpressure[T, M, A](ref: ActorRef[M], messageAdapter: (ActorRef[A], T) => M, onInitMessage: (ActorRef[A]) => M, onCompleteMessage: M, onFailureMessage: (Throwable) => M): Sink[T, NotUsed]

    Sends the elements of the stream to the given ActorRef that sends back back-pressure signals.

    Sends the elements of the stream to the given ActorRef that sends back back-pressure signals. The first element is always onInitMessage, then stream is waiting for acknowledgement message from the given actor which means that it is ready to process elements. It also requires an ack message after each stream element to make backpressure work. This variant will consider any message as ack message.

    If the target actor terminates the stream will be canceled. When the stream is completed successfully the given onCompleteMessage will be sent to the destination actor. When the stream is completed with failure - result of onFailureMessage(throwable) function will be sent to the destination actor.

    ref

    the receiving actor as ActorRef[T] (where T must include the control messages below)

    messageAdapter

    a function that wraps the stream elements to be sent to the actor together with an ActorRef[A] which accepts the ack message

    onInitMessage

    a function that wraps an ActorRef[A] into a messages to couple the receiving actor to the sink

    onCompleteMessage

    the message to be sent to the actor when the stream completes

    onFailureMessage

    a function that creates a message to be sent to the actor in case the stream fails from a Throwable

  6. def actorRefWithBackpressure[T, M, A](ref: ActorRef[M], messageAdapter: (ActorRef[A], T) => M, onInitMessage: (ActorRef[A]) => M, ackMessage: A, onCompleteMessage: M, onFailureMessage: (Throwable) => M): Sink[T, NotUsed]

    Sends the elements of the stream to the given ActorRef that sends back back-pressure signals.

    Sends the elements of the stream to the given ActorRef that sends back back-pressure signals. The first element is always onInitMessage, then stream is waiting for acknowledgement message ackMessage from the given actor which means that it is ready to process elements. It also requires ackMessage message after each stream element to make backpressure work.

    If the target actor terminates the stream will be canceled. When the stream is completed successfully the given onCompleteMessage will be sent to the destination actor. When the stream is completed with failure - result of onFailureMessage(throwable) function will be sent to the destination actor.

    ref

    the receiving actor as ActorRef[T] (where T must include the control messages below)

    messageAdapter

    a function that wraps the stream elements to be sent to the actor together with an ActorRef[A] which accepts the ack message

    onInitMessage

    a function that wraps an ActorRef[A] into a messages to couple the receiving actor to the sink

    ackMessage

    a fixed message that is expected after every element sent to the receiving actor

    onCompleteMessage

    the message to be sent to the actor when the stream completes

    onFailureMessage

    a function that creates a message to be sent to the actor in case the stream fails from a Throwable

  7. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  8. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  9. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  10. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  11. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  12. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  13. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  14. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  15. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  16. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  17. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  18. def toString(): String
    Definition Classes
    AnyRef → Any
  19. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  20. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  21. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from AnyRef

Inherited from Any

Ungrouped