Package akka.stream.extra

Class Timed

java.lang.Object

akka.stream.extra.Timed

public class Timed
extends java.lang.Object

Deprecated.

Moved to the akka/akka-stream-contrib project. Since 2.4.5.

Measures rolling interval between immediately subsequent matching(o: O) elements.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Timed.StartTimed<T>	Deprecated.
static class	Timed.StopTimed<T>	Deprecated.
static class	Timed.TimedFlowContext	Deprecated.
static class	Timed.TimedInterval<T>	Deprecated.

Constructor Summary

Constructors

Constructor	Description
Timed()	Deprecated.

Method Summary

Modifier and Type	Method	Description
static <I,O,Out,Mat,Mat2> Flow<I,Out,Mat2>	timed(Flow<I,O,Mat> flow, scala.Function1<Flow<I,O,Mat>,Flow<I,Out,Mat2>> measuredOps, scala.Function1<scala.concurrent.duration.FiniteDuration,scala.runtime.BoxedUnit> onComplete)	Deprecated.
static <I,O,Mat,Mat2> Source<O,Mat2>	timed(Source<I,Mat> source, scala.Function1<Source<I,Mat>,Source<O,Mat2>> measuredOps, scala.Function1<scala.concurrent.duration.FiniteDuration,scala.runtime.BoxedUnit> onComplete)	Deprecated.
static <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.
static <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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Timed

public Timed()

Deprecated.

Method Detail

timed

public static <I,O,Mat,Mat2> Source<O,Mat2> timed(Source<I,Mat> source,
                                                                          scala.Function1<Source<I,Mat>,Source<O,Mat2>> measuredOps,
                                                                          scala.Function1<scala.concurrent.duration.FiniteDuration,scala.runtime.BoxedUnit> onComplete)

Deprecated.

timed

public static <I,O,Out,Mat,Mat2> Flow<I,Out,Mat2> timed(Flow<I,O,Mat> flow,
                                                                                            scala.Function1<Flow<I,O,Mat>,Flow<I,Out,Mat2>> measuredOps,
                                                                                            scala.Function1<scala.concurrent.duration.FiniteDuration,scala.runtime.BoxedUnit> onComplete)

Deprecated.

timedIntervalBetween

public static <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.

timedIntervalBetween

public static <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.