Package akka.stream.extra
Interface TimedOps
-
- All Known Implementing Classes:
Timed$
public interface TimedOps
INTERNAL APIMeasures time from receiving the first element and completion events - one for each subscriber of this
Flow
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Deprecated Methods Modifier and Type Method 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.<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.
-
-
-
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 APIMeasures 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 APIMeasures 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)
-
-