o

akka.stream.actor

ZeroRequestStrategy

object ZeroRequestStrategy extends RequestStrategy with Product with Serializable

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

Source
ActorSubscriber.scala
Linear Supertypes
Serializable, Serializable, Product, Equals, RequestStrategy, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ZeroRequestStrategy
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. RequestStrategy
  7. AnyRef
  8. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. def getInstance: ZeroRequestStrategy.type

    Java API: get the singleton instance

  2. def requestDemand(remainingRequested: Int): Int

    Invoked by the ActorSubscriber after each incoming message to determine how many more elements to request from the stream.

    Invoked by the ActorSubscriber after each incoming message to determine how many more elements to request from the stream.

    remainingRequested

    current remaining number of elements that have been requested from upstream but not received yet

    returns

    demand of more elements from the stream, returning 0 means that no more elements will be requested for now

    Definition Classes
    ZeroRequestStrategy → RequestStrategy