Class TimedSourceDsl

Provides time measurement utilities on Stream elements.

See Akka.Streams.Extra.Timed

Inheritance

object

TimedSourceDsl

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 TimedSourceDsl

Methods

TimedIntervalBetween<TIn, TMat>(Source<TIn, TMat>, Func<TIn, bool>, Action<TimeSpan>)

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

Declaration

public static Source<TIn, TMat> TimedIntervalBetween<TIn, TMat>(this Source<TIn, TMat> source, Func<TIn, bool> matching, Action<TimeSpan> onInterval)

Parameters

Type	Name	Description
Source<TIn, TMat>	source	TBD
Func<TIn, bool>	matching	TBD
Action<TimeSpan>	onInterval	TBD

Returns

Type	Description
Source<TIn, TMat>	TBD

Type Parameters

Name	Description
TIn	TBD
TMat	TBD

Timed<TIn, TOut, TMat, TMat2>(Source<TIn, TMat>, Func<Source<TIn, TMat>, Source<TOut, 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 Source<TOut, TMat2> Timed<TIn, TOut, TMat, TMat2>(this Source<TIn, TMat> source, Func<Source<TIn, TMat>, Source<TOut, TMat2>> measuredOps, Action<TimeSpan> onComplete)

Parameters

Type	Name	Description
Source<TIn, TMat>	source	TBD
Func<Source<TIn, TMat>, Source<TOut, TMat2>>	measuredOps	TBD
Action<TimeSpan>	onComplete	TBD

Returns

Type	Description
Source<TOut, TMat2>	TBD

Type Parameters

Name	Description
TIn	TBD
TOut	TBD
TMat	TBD
TMat2	TBD