public class OneByOneRequestStrategy$ extends java.lang.Object implements RequestStrategy, scala.Product, scala.Serializable
remainingRequested
is 0, i.e.
max one element in flight.Modifier and Type | Field and Description |
---|---|
static OneByOneRequestStrategy$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
OneByOneRequestStrategy$() |
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. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public static final OneByOneRequestStrategy$ MODULE$
public int requestDemand(int remainingRequested)
RequestStrategy
ActorSubscriber
after each incoming message to
determine how many more elements to request from the stream.
requestDemand
in interface RequestStrategy
remainingRequested
- current remaining number of elements that
have been requested from upstream but not received yetpublic OneByOneRequestStrategy$ getInstance()