Class TimedFlowDsl

Provides time measurement utilities on Stream elements.

See Akka.Streams.Extra.Timed

Inheritance

Object

TimedFlowDsl

Inherited Members

Object.Equals(Object)

Object.Equals(Object, Object)

Object.GetHashCode()

Object.GetType()

Object.MemberwiseClone()

Object.ReferenceEquals(Object, Object)

Object.ToString()

Namespace: Akka.Streams.Extra

Assembly: Akka.Streams.dll

Syntax

public static class TimedFlowDsl

Methods

Timed<TIn, TOut, TOut2, TMat, TMat2>(Flow<TIn, TOut, TMat>, Func<Flow<TIn, TOut, TMat>, Flow<TIn, TOut2, TMat2>>, Action<TimeSpan>)

Measures time from receiving the first element and completion events - one for each subscriber of this IFlow<TOut, TMat>.

Declaration

public 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)

Parameters

Type	Name	Description
Flow<TIn, TOut, TMat>	flow	TBD
Func<Flow<TIn, TOut, TMat>, Flow<TIn, TOut2, TMat2>>	measuredOps	TBD
Action<TimeSpan>	onComplete	TBD

Returns

Type	Description
Flow<TIn, TOut2, TMat2>	TBD

Type Parameters

Name	Description
TIn	TBD
TOut	TBD
TOut2	TBD
TMat	TBD
TMat2	TBD

TimedIntervalBetween<TIn, TOut, TMat>(Flow<TIn, TOut, TMat>, Func<TOut, Boolean>, Action<TimeSpan>)

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

Declaration

public static Flow<TIn, TOut, TMat> TimedIntervalBetween<TIn, TOut, TMat>(this Flow<TIn, TOut, TMat> flow, Func<TOut, bool> matching, Action<TimeSpan> onInterval)

Parameters

Type	Name	Description
Flow<TIn, TOut, TMat>	flow	TBD
Func<TOut, Boolean>	matching	TBD
Action<TimeSpan>	onInterval	TBD

Returns

Type	Description
Flow<TIn, TOut, TMat>	TBD

Type Parameters

Name	Description
TIn	TBD
TOut	TBD
TMat	TBD