Constructor and Description |
---|
TimedSourceDsl(Source<I,Mat> source) |
Modifier and Type | Method and Description |
---|---|
Source<I,Mat> |
source() |
<O,Mat2> Source<O,Mat2> |
timed(scala.Function1<Source<I,Mat>,Source<O,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 . |
Source<I,Mat> |
timedIntervalBetween(scala.Function1<I,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 <O,Mat2> Source<O,Mat2> timed(scala.Function1<Source<I,Mat>,Source<O,Mat2>> measuredOps, scala.Function1<scala.concurrent.duration.FiniteDuration,scala.runtime.BoxedUnit> onComplete)
Flow
.measuredOps
- (undocumented)onComplete
- (undocumented)public Source<I,Mat> timedIntervalBetween(scala.Function1<I,java.lang.Object> matching, scala.Function1<scala.concurrent.duration.FiniteDuration,scala.runtime.BoxedUnit> onInterval)
matching(o: O)
elements.matching
- (undocumented)onInterval
- (undocumented)