Click or drag to resize
Akka.NETTestPublisherManualProbeTReceiveWhileTOther Method
Receive messages for a given duration or until one does not match a given partial function.

Namespace:  Akka.Streams.TestKit
Assembly:  Akka.Streams.TestKit (in Akka.Streams.TestKit.dll) Version: 1.0.0.0 (1.0.0.0)
Syntax
public IEnumerable<TOther> ReceiveWhile<TOther>(
	Nullable<TimeSpan> max = null,
	Nullable<TimeSpan> idle = null,
	Func<Object, TOther> filter = null,
	int msgs = 2147483647
)
where TOther : class

Parameters

max (Optional)
Type: SystemNullableTimeSpan

[Missing <param name="max"/> documentation for "M:Akka.Streams.TestKit.TestPublisher.ManualProbe`1.ReceiveWhile``1(System.Nullable{System.TimeSpan},System.Nullable{System.TimeSpan},System.Func{System.Object,``0},System.Int32)"]

idle (Optional)
Type: SystemNullableTimeSpan

[Missing <param name="idle"/> documentation for "M:Akka.Streams.TestKit.TestPublisher.ManualProbe`1.ReceiveWhile``1(System.Nullable{System.TimeSpan},System.Nullable{System.TimeSpan},System.Func{System.Object,``0},System.Int32)"]

filter (Optional)
Type: SystemFuncObject, TOther

[Missing <param name="filter"/> documentation for "M:Akka.Streams.TestKit.TestPublisher.ManualProbe`1.ReceiveWhile``1(System.Nullable{System.TimeSpan},System.Nullable{System.TimeSpan},System.Func{System.Object,``0},System.Int32)"]

msgs (Optional)
Type: SystemInt32

[Missing <param name="msgs"/> documentation for "M:Akka.Streams.TestKit.TestPublisher.ManualProbe`1.ReceiveWhile``1(System.Nullable{System.TimeSpan},System.Nullable{System.TimeSpan},System.Func{System.Object,``0},System.Int32)"]

Type Parameters

TOther

[Missing <typeparam name="TOther"/> documentation for "M:Akka.Streams.TestKit.TestPublisher.ManualProbe`1.ReceiveWhile``1(System.Nullable{System.TimeSpan},System.Nullable{System.TimeSpan},System.Func{System.Object,``0},System.Int32)"]

Return Value

Type: IEnumerableTOther

[Missing <returns> documentation for "M:Akka.Streams.TestKit.TestPublisher.ManualProbe`1.ReceiveWhile``1(System.Nullable{System.TimeSpan},System.Nullable{System.TimeSpan},System.Func{System.Object,``0},System.Int32)"]

See Also