Package akka.stream.extra
Interface TimedIntervalBetweenOps
-
- All Known Implementing Classes:
Timed$
public interface TimedIntervalBetweenOps
Measures rolling interval between immediately subsequentmatching(o: O)
elements.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Deprecated Methods Modifier and Type Method Description <I,O,Mat>
Flow<I,O,Mat>timedIntervalBetween(Flow<I,O,Mat> flow, scala.Function1<O,java.lang.Object> matching, scala.Function1<scala.concurrent.duration.FiniteDuration,scala.runtime.BoxedUnit> onInterval)
Deprecated.Moved to the akka/akka-stream-contrib project.<O,Mat>
Source<O,Mat>timedIntervalBetween(Source<O,Mat> source, scala.Function1<O,java.lang.Object> matching, scala.Function1<scala.concurrent.duration.FiniteDuration,scala.runtime.BoxedUnit> onInterval)
Deprecated.Moved to the akka/akka-stream-contrib project.
-
-
-
Method Detail
-
timedIntervalBetween
<O,Mat> Source<O,Mat> timedIntervalBetween(Source<O,Mat> source, scala.Function1<O,java.lang.Object> matching, scala.Function1<scala.concurrent.duration.FiniteDuration,scala.runtime.BoxedUnit> onInterval)
Deprecated.Moved to the akka/akka-stream-contrib project. Since 2.4.5.Measures rolling interval between immediately subsequentmatching(o: O)
elements.- Parameters:
source
- (undocumented)matching
- (undocumented)onInterval
- (undocumented)- Returns:
- (undocumented)
-
timedIntervalBetween
<I,O,Mat> Flow<I,O,Mat> timedIntervalBetween(Flow<I,O,Mat> flow, scala.Function1<O,java.lang.Object> matching, scala.Function1<scala.concurrent.duration.FiniteDuration,scala.runtime.BoxedUnit> onInterval)
Deprecated.Moved to the akka/akka-stream-contrib project. Since 2.4.5.Measures rolling interval between immediately subsequentmatching(o: O)
elements.- Parameters:
flow
- (undocumented)matching
- (undocumented)onInterval
- (undocumented)- Returns:
- (undocumented)
-
-