Package akka.stream.extra
Class Implicits.TimedFlowDsl$
- java.lang.Object
-
- akka.stream.extra.Implicits.TimedFlowDsl$
-
- Enclosing class:
- Implicits
public static class Implicits.TimedFlowDsl$ extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description static Implicits.TimedFlowDsl$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description TimedFlowDsl$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <I,O,Mat>
booleanequals$extension(Implicits.TimedFlowDsl<I,O,Mat> $this, java.lang.Object x$1)
<I,O,Mat>
inthashCode$extension(Implicits.TimedFlowDsl<I,O,Mat> $this)
<Out,Mat2,I,O,Mat>
Flow<I,Out,Mat2>timed$extension(Implicits.TimedFlowDsl<I,O,Mat> $this, scala.Function1<Flow<I,O,Mat>,Flow<I,Out,Mat2>> measuredOps, scala.Function1<scala.concurrent.duration.FiniteDuration,scala.runtime.BoxedUnit> onComplete)
Measures time from receiving the first element and completion events - one for each subscriber of thisFlow
.<I,O,Mat>
Flow<I,O,Mat>timedIntervalBetween$extension(Implicits.TimedFlowDsl<I,O,Mat> $this, scala.Function1<O,java.lang.Object> matching, scala.Function1<scala.concurrent.duration.FiniteDuration,scala.runtime.BoxedUnit> onInterval)
Measures rolling interval between immediately subsequentmatching(o: O)
elements.
-
-
-
Field Detail
-
MODULE$
public static final Implicits.TimedFlowDsl$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
timed$extension
public final <Out,Mat2,I,O,Mat> Flow<I,Out,Mat2> timed$extension(Implicits.TimedFlowDsl<I,O,Mat> $this, scala.Function1<Flow<I,O,Mat>,Flow<I,Out,Mat2>> measuredOps, scala.Function1<scala.concurrent.duration.FiniteDuration,scala.runtime.BoxedUnit> onComplete)
Measures time from receiving the first element and completion events - one for each subscriber of thisFlow
.- Parameters:
$this
- (undocumented)measuredOps
- (undocumented)onComplete
- (undocumented)- Returns:
- (undocumented)
-
timedIntervalBetween$extension
public final <I,O,Mat> Flow<I,O,Mat> timedIntervalBetween$extension(Implicits.TimedFlowDsl<I,O,Mat> $this, scala.Function1<O,java.lang.Object> matching, scala.Function1<scala.concurrent.duration.FiniteDuration,scala.runtime.BoxedUnit> onInterval)
Measures rolling interval between immediately subsequentmatching(o: O)
elements.- Parameters:
$this
- (undocumented)matching
- (undocumented)onInterval
- (undocumented)- Returns:
- (undocumented)
-
hashCode$extension
public final <I,O,Mat> int hashCode$extension(Implicits.TimedFlowDsl<I,O,Mat> $this)
-
equals$extension
public final <I,O,Mat> boolean equals$extension(Implicits.TimedFlowDsl<I,O,Mat> $this, java.lang.Object x$1)
-
-