Package akka.stream.extra
Class Implicits.TimedFlowDsl<I,O,Mat>
- java.lang.Object
-
- scala.AnyVal
-
- akka.stream.extra.Implicits.TimedFlowDsl<I,O,Mat>
-
- Enclosing class:
- Implicits
public static class Implicits.TimedFlowDsl<I,O,Mat> extends scala.AnyVal
-
-
Constructor Summary
Constructors Constructor Description TimedFlowDsl(Flow<I,O,Mat> flow)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(java.lang.Object x$1)
Flow<I,O,Mat>
flow()
int
hashCode()
<Out,Mat2>
Flow<I,Out,Mat2>timed(scala.Function1<Flow<I,O,Mat>,Flow<I,Out,Mat2>> measuredOps, scala.Function1<scala.concurrent.duration.FiniteDuration,scala.runtime.BoxedUnit> onComplete)
Flow<I,O,Mat>
timedIntervalBetween(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.
-
-
-
Method Detail
-
timed
public <Out,Mat2> Flow<I,Out,Mat2> timed(scala.Function1<Flow<I,O,Mat>,Flow<I,Out,Mat2>> measuredOps, scala.Function1<scala.concurrent.duration.FiniteDuration,scala.runtime.BoxedUnit> onComplete)
-
timedIntervalBetween
public Flow<I,O,Mat> timedIntervalBetween(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:
matching
- (undocumented)onInterval
- (undocumented)- Returns:
- (undocumented)
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
equals
public boolean equals(java.lang.Object x$1)
- Overrides:
equals
in classjava.lang.Object
-
-