Package akka.stream.actor
Class WatermarkRequestStrategy
- java.lang.Object
-
- akka.stream.actor.WatermarkRequestStrategy
-
- All Implemented Interfaces:
RequestStrategy
,java.io.Serializable
,scala.Equals
,scala.Product
,scala.Serializable
public final class WatermarkRequestStrategy extends java.lang.Object implements RequestStrategy, scala.Product, scala.Serializable
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description WatermarkRequestStrategy(int highWatermark)
WatermarkRequestStrategy(int highWatermark, int lowWatermark)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static WatermarkRequestStrategy
apply(int highWatermark)
static WatermarkRequestStrategy
apply(int highWatermark, int lowWatermark)
Requests up to thehighWatermark
when theremainingRequested
is below thelowWatermark
.boolean
canEqual(java.lang.Object x$1)
WatermarkRequestStrategy
copy(int highWatermark, int lowWatermark)
int
copy$default$1()
int
copy$default$2()
boolean
equals(java.lang.Object x$1)
int
hashCode()
int
highWatermark()
int
lowWatermark()
int
productArity()
java.lang.Object
productElement(int x$1)
scala.collection.Iterator<java.lang.Object>
productIterator()
java.lang.String
productPrefix()
int
requestDemand(int remainingRequested)
java.lang.String
toString()
static scala.Option<scala.Tuple2<java.lang.Object,java.lang.Object>>
unapply(WatermarkRequestStrategy x$0)
-
-
-
Method Detail
-
apply
public static WatermarkRequestStrategy apply(int highWatermark)
-
apply
public static WatermarkRequestStrategy apply(int highWatermark, int lowWatermark)
Requests up to thehighWatermark
when theremainingRequested
is below thelowWatermark
. This a good strategy when the actor performs work itself.- Parameters:
highWatermark
- (undocumented)lowWatermark
- (undocumented)- Returns:
- (undocumented)
-
unapply
public static scala.Option<scala.Tuple2<java.lang.Object,java.lang.Object>> unapply(WatermarkRequestStrategy x$0)
-
highWatermark
public int highWatermark()
-
lowWatermark
public int lowWatermark()
-
requestDemand
public int requestDemand(int remainingRequested)
- Specified by:
requestDemand
in interfaceRequestStrategy
-
copy
public WatermarkRequestStrategy copy(int highWatermark, int lowWatermark)
-
copy$default$1
public int copy$default$1()
-
copy$default$2
public int copy$default$2()
-
productPrefix
public java.lang.String productPrefix()
- Specified by:
productPrefix
in interfacescala.Product
-
productArity
public int productArity()
- Specified by:
productArity
in interfacescala.Product
-
productElement
public java.lang.Object productElement(int x$1)
- Specified by:
productElement
in interfacescala.Product
-
productIterator
public scala.collection.Iterator<java.lang.Object> productIterator()
- Specified by:
productIterator
in interfacescala.Product
-
canEqual
public boolean canEqual(java.lang.Object x$1)
- Specified by:
canEqual
in interfacescala.Equals
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
equals
public boolean equals(java.lang.Object x$1)
- Specified by:
equals
in interfacescala.Equals
- Overrides:
equals
in classjava.lang.Object
-
-