WatermarkRequestStrategy$

java.lang.Object
- akka.stream.actor.WatermarkRequestStrategy$

All Implemented Interfaces:

java.io.Serializable, scala.Serializable
```
public class WatermarkRequestStrategy$
extends java.lang.Object
implements scala.Serializable
```
Create WatermarkRequestStrategy with lowWatermark as half of the specified highWatermark.

See Also:

Serialized Form

Field Summary

Fields
Modifier and Type Field Description

static WatermarkRequestStrategy$ MODULE$
Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors
Constructor Description

WatermarkRequestStrategy$()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`WatermarkRequestStrategy`	`apply(int highWatermark)`
`WatermarkRequestStrategy`	`apply(int highWatermark, int lowWatermark)`	Requests up to the `highWatermark` when the `remainingRequested` is below the `lowWatermark`.
`scala.Option<scala.Tuple2<java.lang.Object,java.lang.Object>>`	`unapply(WatermarkRequestStrategy x$0)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail
- MODULE$
```
public static final WatermarkRequestStrategy$ MODULE$
```
  Static reference to the singleton instance of this Scala object.

Constructor Detail
- WatermarkRequestStrategy$
```
public WatermarkRequestStrategy$()
```

Method Detail

apply

public WatermarkRequestStrategy apply(int highWatermark)

apply
```
public WatermarkRequestStrategy apply(int highWatermark,
                                      int lowWatermark)
```
Requests up to the highWatermark when the remainingRequested is below the lowWatermark. This a good strategy when the actor performs work itself.

Parameters:

highWatermark - (undocumented)

lowWatermark - (undocumented)

Returns:

(undocumented)

unapply

public scala.Option<scala.Tuple2<java.lang.Object,java.lang.Object>> unapply(WatermarkRequestStrategy x$0)