public class Timed
extends java.lang.Object
Modifier and Type | Class and 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 and Description |
---|
Timed()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static <I,O,Out,Mat,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> |
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.
|
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)
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)
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)