Constructor and Description |
---|
TimedFlowDsl(Flow<I,O,Mat> flow) |
Modifier and Type | Method and Description |
---|---|
Flow<I,O,Mat> |
flow() |
<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)
Measures time from receiving the first element and completion events - one for each subscriber of this
Flow . |
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 subsequent
matching(o: O) elements. |
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)
Flow
.measuredOps
- (undocumented)onComplete
- (undocumented)public Flow<I,O,Mat> timedIntervalBetween(scala.Function1<O,java.lang.Object> matching, scala.Function1<scala.concurrent.duration.FiniteDuration,scala.runtime.BoxedUnit> onInterval)
matching(o: O)
elements.matching
- (undocumented)onInterval
- (undocumented)