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

TimedIntervalBetween<TIn, TOut, TMat>(Flow<TIn, TOut, TMat>, Func<TOut, bool>, 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, bool>	matching	TBD
Action<TimeSpan>	onInterval	TBD

Returns

Type	Description
Flow<TIn, TOut, TMat>	TBD

Type Parameters

Name	Description
TIn	TBD
TOut	TBD
TMat	TBD

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