akka.stream.actor

Class WatermarkRequestStrategy

java.lang.Object

akka.stream.actor.WatermarkRequestStrategy

All Implemented Interfaces:

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

public final class WatermarkRequestStrategy
extends java.lang.Object
implements RequestStrategy, scala.Product, scala.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
WatermarkRequestStrategy(int highWatermark) Create WatermarkRequestStrategy with lowWatermark as half of the specified highWatermark.
WatermarkRequestStrategy(int highWatermark, int lowWatermark)

Method Summary

Modifier and Type	Method and Description
static WatermarkRequestStrategy	apply(int highWatermark) Create WatermarkRequestStrategy with lowWatermark as half of the specified 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.

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

Constructor Detail

WatermarkRequestStrategy

public WatermarkRequestStrategy(int highWatermark,
                                int lowWatermark)

WatermarkRequestStrategy

public WatermarkRequestStrategy(int highWatermark)

Create WatermarkRequestStrategy with lowWatermark as half of the specified highWatermark.

Parameters:

highWatermark - (undocumented)

Method Detail

apply

public static WatermarkRequestStrategy apply(int highWatermark)

Create WatermarkRequestStrategy with lowWatermark as half of the specified highWatermark.

Parameters:

highWatermark - (undocumented)

Returns:

(undocumented)

canEqual

public abstract static boolean canEqual(java.lang.Object that)

equals

public abstract static boolean equals(java.lang.Object that)

productElement

public abstract static java.lang.Object productElement(int n)

productArity

public abstract static int productArity()

productIterator

public static scala.collection.Iterator<java.lang.Object> productIterator()

productPrefix

public static java.lang.String productPrefix()

highWatermark

public int highWatermark()

lowWatermark

public int lowWatermark()

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