akka.stream.extra

Interface TimedOps

All Known Implementing Classes:

Timed$

public interface TimedOps

Provides operations needed to implement the timed DSL

Method Summary

Modifier and Type	Method and Description
<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. Moved to the akka/akka-stream-contrib project. Since 2.4.5.
<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. Moved to the akka/akka-stream-contrib project. Since 2.4.5.

Method Detail

timed

<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. Moved to the akka/akka-stream-contrib project. Since 2.4.5.

INTERNAL API

Measures time from receiving the first element and completion events - one for each subscriber of this Flow.

Parameters:

source - (undocumented)

measuredOps - (undocumented)

onComplete - (undocumented)

Returns:

(undocumented)

timed

<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. Moved to the akka/akka-stream-contrib project. Since 2.4.5.

INTERNAL API

Measures time from receiving the first element and completion events - one for each subscriber of this Flow.

Parameters:

flow - (undocumented)

measuredOps - (undocumented)

onComplete - (undocumented)

Returns:

(undocumented)