Package akka.stream.impl.streamref
Class SourceRefStageImpl.WatermarkRequestStrategy$
- java.lang.Object
-
- akka.stream.impl.streamref.SourceRefStageImpl.WatermarkRequestStrategy$
-
- All Implemented Interfaces:
java.io.Serializable
- Enclosing class:
- SourceRefStageImpl<Out>
public static class SourceRefStageImpl.WatermarkRequestStrategy$ extends java.lang.Object implements java.io.Serializable
- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description static SourceRefStageImpl.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 SourceRefStageImpl.WatermarkRequestStrategy
apply(int highWatermark)
CreateSourceRefStageImpl.WatermarkRequestStrategy
withlowWatermark
as half of the specifiedhighWatermark
.SourceRefStageImpl.WatermarkRequestStrategy
apply(int highWatermark, int lowWatermark)
Requests up to thehighWatermark
when theremainingRequested
is below thelowWatermark
.scala.Option<scala.Tuple2<java.lang.Object,java.lang.Object>>
unapply(SourceRefStageImpl.WatermarkRequestStrategy x$0)
-
-
-
Field Detail
-
MODULE$
public static final SourceRefStageImpl.WatermarkRequestStrategy$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
apply
public SourceRefStageImpl.WatermarkRequestStrategy apply(int highWatermark)
CreateSourceRefStageImpl.WatermarkRequestStrategy
withlowWatermark
as half of the specifiedhighWatermark
.
-
apply
public SourceRefStageImpl.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.
-
unapply
public scala.Option<scala.Tuple2<java.lang.Object,java.lang.Object>> unapply(SourceRefStageImpl.WatermarkRequestStrategy x$0)
-
-