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

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

TimedIntervalBetween<TIn, TMat>(Source<TIn, TMat>, Func<TIn, Boolean>, 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, Boolean>	matching	TBD
Action<TimeSpan>	onInterval	TBD

Returns

Type	Description
Source<TIn, TMat>	TBD

Type Parameters

Name	Description
TIn	TBD
TMat	TBD