akka.stream.actor

ActorConsumer

object ActorConsumer

Source
ActorConsumer.scala
Linear Supertypes
Content Hierarchy Learn more about scaladoc diagrams
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. ActorConsumer
  2. AnyRef
  3. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Type Members

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

    Requests up to the max and also takes the number of messages that have been queued internally or delegated to other actors into account. Concrete subclass must implement #inFlightInternally. It will request elements in minimum batches of the defined #batchSize.

  2. case class OnError(cause: Throwable) extends Product with Serializable

    Annotations
    @SerialVersionUID()
  3. case class OnNext(element: Any) extends Product with Serializable

    Annotations
    @SerialVersionUID()
  4. trait RequestStrategy extends AnyRef

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

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

    Requests up to the highWatermark when the remainingRequested is below the lowWatermark. This a good strategy when the actor performs work itself.

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. object OnComplete extends Product with Serializable

    Annotations
    @SerialVersionUID()
  5. object OneByOneRequestStrategy extends RequestStrategy with Product with Serializable

    Requests one more element when remainingRequested is 0, i.

    Requests one more element when remainingRequested is 0, i.e. max one element in flight.

  6. object WatermarkRequestStrategy extends Serializable

  7. object ZeroRequestStrategy extends RequestStrategy with Product with Serializable

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

  8. def apply[T](ref: ActorRef): Consumer[T]

    Attach a ActorConsumer actor as a org.reactivestreams.api.Consumer to a org.reactivestreams.api.Producer or akka.stream.Flow.

  9. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  10. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  11. def create[T](ref: ActorRef): Consumer[T]

    Java API: Attach a ActorConsumer actor as a org.reactivestreams.api.Consumer to a org.reactivestreams.api.Producer or akka.stream.Flow.

  12. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  13. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  14. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  15. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  16. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  17. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  18. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  19. final def notify(): Unit

    Definition Classes
    AnyRef
  20. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  21. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  22. def toString(): String

    Definition Classes
    AnyRef → Any
  23. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  24. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  25. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped