public final class WatermarkRequestStrategy extends java.lang.Object implements RequestStrategy, scala.Product, scala.Serializable
Constructor and Description |
---|
WatermarkRequestStrategy(int highWatermark)
|
WatermarkRequestStrategy(int highWatermark,
int lowWatermark) |
Modifier and Type | Method and Description |
---|---|
static WatermarkRequestStrategy |
apply(int highWatermark)
|
abstract static boolean |
canEqual(java.lang.Object that) |
abstract static boolean |
equals(java.lang.Object that) |
int |
highWatermark() |
int |
lowWatermark() |
abstract static int |
productArity() |
abstract static java.lang.Object |
productElement(int n) |
static scala.collection.Iterator<java.lang.Object> |
productIterator() |
static java.lang.String |
productPrefix() |
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 WatermarkRequestStrategy(int highWatermark, int lowWatermark)
public WatermarkRequestStrategy(int highWatermark)
highWatermark
- (undocumented)public static WatermarkRequestStrategy apply(int highWatermark)
highWatermark
- (undocumented)public abstract static boolean canEqual(java.lang.Object that)
public abstract static boolean equals(java.lang.Object that)
public abstract static java.lang.Object productElement(int n)
public abstract static int productArity()
public static scala.collection.Iterator<java.lang.Object> productIterator()
public static java.lang.String productPrefix()
public int highWatermark()
public int lowWatermark()
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 yet