akka.stream.actor

Class OneByOneRequestStrategy$

java.lang.Object

akka.stream.actor.OneByOneRequestStrategy$

All Implemented Interfaces:

RequestStrategy, java.io.Serializable, scala.Equals, scala.Product

public class OneByOneRequestStrategy$
extends java.lang.Object
implements RequestStrategy, scala.Product, scala.Serializable

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

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static OneByOneRequestStrategy$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
OneByOneRequestStrategy$()

Method Summary

Modifier and Type	Method and Description
OneByOneRequestStrategy$	getInstance() Java API: get the singleton instance
int	requestDemand(int remainingRequested) Invoked by the ActorSubscriber after each incoming message to determine how many more elements to request from the stream.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface scala.Product

$init$, productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Field Detail

MODULE$

public static final OneByOneRequestStrategy$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

OneByOneRequestStrategy$

public OneByOneRequestStrategy$()

Method Detail

requestDemand

public int requestDemand(int remainingRequested)

Description copied from interface: RequestStrategy

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

Specified by:

requestDemand in interface RequestStrategy

Parameters:

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

getInstance

public OneByOneRequestStrategy$ getInstance()

Java API: get the singleton instance

Returns:

(undocumented)