 | TimedFlowDsl.Timed<TIn, TOut, TOut2, TMat, TMat2> Method |
Measures time from receiving the first element and completion events - one for each subscriber of this
IFlow<TOut, TMat>.
Namespace:
Akka.Streams.Extra
Assembly:
Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.42 (1.2.3.42)
Syntaxpublic static Flow<TIn, TOut2, TMat2> Timed<TIn, TOut, TOut2, TMat, TMat2>(
this Flow<TIn, TOut, TMat> flow,
Func<Flow<TIn, TOut, TMat>, Flow<TIn, TOut2, TMat2>> measuredOps,
Action<TimeSpan> onComplete
)
[<ExtensionAttribute>]
static member Timed :
flow : Flow<'TIn, 'TOut, 'TMat> *
measuredOps : Func<Flow<'TIn, 'TOut, 'TMat>, Flow<'TIn, 'TOut2, 'TMat2>> *
onComplete : Action<TimeSpan> -> Flow<'TIn, 'TOut2, 'TMat2>
Parameters
- flow
- Type: Akka.Streams.Dsl.Flow<TIn, TOut, TMat>
TBD - measuredOps
- Type: System.Func<Flow<TIn, TOut, TMat>, Flow<TIn, TOut2, TMat2>>
TBD - onComplete
- Type: System.Action<TimeSpan>
TBD
Type Parameters
- TIn
- TBD
- TOut
- TBD
- TOut2
- TBD
- TMat
- TBD
- TMat2
- TBD
Return Value
Type:
Flow<TIn,
TOut2,
TMat2>TBD
Usage Note
In Visual Basic and C#, you can call this method as an instance method on any object of type
Flow<TIn,
TOut,
TMat>. When you use instance method syntax to call this method, omit the first parameter. For more information, see
Extension Methods (Visual Basic) or
Extension Methods (C# Programming Guide).
See Also