akka.stream.extra

Interface TimedIntervalBetweenOps

All Known Implementing Classes:

Timed$

public interface TimedIntervalBetweenOps

INTERNAL API

Provides operations needed to implement the timedIntervalBetween DSL

Method Summary

Modifier and Type	Method and 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. Since 2.4.5.
<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.

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 subsequent matching(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 subsequent matching(o: O) elements.

Parameters:

flow - (undocumented)

matching - (undocumented)

onInterval - (undocumented)

Returns:

(undocumented)