Class TestSubscriber.ManualProbe<T>

Implementation of Reactive.Streams.ISubscriber{T} that allows various assertions. All timeouts are dilated automatically, for more details about time dilation refer to Akka.Streams.TestKit.

Inheritance
Object
TestSubscriber.ManualProbe<T>
TestSubscriber.Probe<T>
Implements
Reactive.Streams.ISubscriber<T>
Inherited Members
Namespace: Akka.Streams.TestKit
Assembly: Akka.Streams.TestKit.dll
Syntax
public class ManualProbe<T> : ISubscriber<T>
Type Parameters
Name Description
T

Properties

| Improve this Doc View Source

Subscription

Declaration
public ISubscription Subscription { get; protected set; }
Property Value
Type Description
Reactive.Streams.ISubscription

Methods

| Improve this Doc View Source

AsyncBuilder()

Fluent async DSL. This will return an instance of SubscriberFluentBuilder<T> that will compose and run all of its method call asynchronously. Note that SubscriberFluentBuilder<T> contains two types of methods:

  • Methods that returns SubscriberFluentBuilder<T> are used to chain test methods together using a fluent builder pattern.
  • Methods with names that ends with the postfix "Async" and returns either a Task or a Task<TResult>. These methods invokes the previously chained methods asynchronously one after another before executing its own code.
Declaration
public SubscriberFluentBuilder<T> AsyncBuilder()
Returns
Type Description
SubscriberFluentBuilder<T>
| Improve this Doc View Source

ExpectComplete(Nullable<TimeSpan>, CancellationToken)

Fluent DSL. Expect completion with a timeout.

Declaration
public TestSubscriber.ManualProbe<T> ExpectComplete(TimeSpan? timeout, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
Nullable<TimeSpan> timeout
CancellationToken cancellationToken
Returns
Type Description
TestSubscriber.ManualProbe<T>
| Improve this Doc View Source

ExpectComplete(CancellationToken)

Fluent DSL. Expect completion.

Declaration
public TestSubscriber.ManualProbe<T> ExpectComplete(CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
TestSubscriber.ManualProbe<T>
| Improve this Doc View Source

ExpectCompleteAsync(CancellationToken)

Declaration
public async Task ExpectCompleteAsync(CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
Task
| Improve this Doc View Source

ExpectError(CancellationToken)

Expect and return the signalled System.Exception/>.

Declaration
public Exception ExpectError(CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
Exception
| Improve this Doc View Source

ExpectErrorAsync(CancellationToken)

Expect and return the signalled System.Exception/>.

Declaration
public async Task<Exception> ExpectErrorAsync(CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
Task<Exception>
| Improve this Doc View Source

ExpectEvent(TestSubscriber.ISubscriberEvent, CancellationToken)

Fluent DSL. Expect and return TestSubscriber.ISubscriberEvent (any of: OnSubscribe(ISubscription), OnNext(T), OnError(Exception) or OnComplete()).

Declaration
public TestSubscriber.ManualProbe<T> ExpectEvent(TestSubscriber.ISubscriberEvent e, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
TestSubscriber.ISubscriberEvent e
CancellationToken cancellationToken
Returns
Type Description
TestSubscriber.ManualProbe<T>
| Improve this Doc View Source

ExpectEvent(CancellationToken)

Expect and return TestSubscriber.ISubscriberEvent (any of: OnSubscribe(ISubscription), OnNext(T), OnError(Exception) or OnComplete()).

Declaration
public TestSubscriber.ISubscriberEvent ExpectEvent(CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
TestSubscriber.ISubscriberEvent
| Improve this Doc View Source

ExpectEvent(TimeSpan, CancellationToken)

Expect and return TestSubscriber.ISubscriberEvent (any of: OnSubscribe(ISubscription), OnNext(T), OnError(Exception) or OnComplete()).

Declaration
public TestSubscriber.ISubscriberEvent ExpectEvent(TimeSpan max, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
TimeSpan max
CancellationToken cancellationToken
Returns
Type Description
TestSubscriber.ISubscriberEvent
| Improve this Doc View Source

ExpectEvent<TOther>(Func<TestSubscriber.ISubscriberEvent, TOther>, CancellationToken)

Declaration
public TOther ExpectEvent<TOther>(Func<TestSubscriber.ISubscriberEvent, TOther> func, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
Func<TestSubscriber.ISubscriberEvent, TOther> func
CancellationToken cancellationToken
Returns
Type Description
TOther
Type Parameters
Name Description
TOther
| Improve this Doc View Source

ExpectEventAsync(Nullable<TimeSpan>, CancellationToken)

Expect and return TestSubscriber.ISubscriberEvent (any of: OnSubscribe(ISubscription), OnNext(T), OnError(Exception) or OnComplete()).

Declaration
public async Task<TestSubscriber.ISubscriberEvent> ExpectEventAsync(TimeSpan? max, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
Nullable<TimeSpan> max
CancellationToken cancellationToken
Returns
Type Description
Task<TestSubscriber.ISubscriberEvent>
| Improve this Doc View Source

ExpectEventAsync(CancellationToken)

Expect and return TestSubscriber.ISubscriberEvent (any of: OnSubscribe(ISubscription), OnNext(T), OnError(Exception) or OnComplete()).

Declaration
public async Task<TestSubscriber.ISubscriberEvent> ExpectEventAsync(CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
Task<TestSubscriber.ISubscriberEvent>
| Improve this Doc View Source

ExpectEventAsync<TOther>(Func<TestSubscriber.ISubscriberEvent, TOther>, CancellationToken)

Declaration
public async Task<TOther> ExpectEventAsync<TOther>(Func<TestSubscriber.ISubscriberEvent, TOther> func, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
Func<TestSubscriber.ISubscriberEvent, TOther> func
CancellationToken cancellationToken
Returns
Type Description
Task<TOther>
Type Parameters
Name Description
TOther
| Improve this Doc View Source

ExpectNext(T, Nullable<TimeSpan>, CancellationToken)

Fluent DSL. Expect a stream element.

Declaration
public TestSubscriber.ManualProbe<T> ExpectNext(T element, TimeSpan? timeout = null, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
T element
Nullable<TimeSpan> timeout
CancellationToken cancellationToken
Returns
Type Description
TestSubscriber.ManualProbe<T>
| Improve this Doc View Source

ExpectNext(T[])

Fluent DSL. Expect multiple stream elements.

Declaration
public TestSubscriber.ManualProbe<T> ExpectNext(params T[] elems)
Parameters
Type Name Description
T[] elems
Returns
Type Description
TestSubscriber.ManualProbe<T>
| Improve this Doc View Source

ExpectNext(Nullable<TimeSpan>, T, CancellationToken)

Fluent DSL. Expect a stream element during specified time or timeout.

Declaration
public TestSubscriber.ManualProbe<T> ExpectNext(TimeSpan? timeout, T element, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
Nullable<TimeSpan> timeout
T element
CancellationToken cancellationToken
Returns
Type Description
TestSubscriber.ManualProbe<T>
| Improve this Doc View Source

ExpectNext(Nullable<TimeSpan>, T[])

Fluent DSL. Expect multiple stream elements.

Declaration
[Obsolete("Use the method with CancellationToken support instead")]
public TestSubscriber.ManualProbe<T> ExpectNext(TimeSpan? timeout, params T[] elems)
Parameters
Type Name Description
Nullable<TimeSpan> timeout
T[] elems
Returns
Type Description
TestSubscriber.ManualProbe<T>
| Improve this Doc View Source

ExpectNext(Nullable<TimeSpan>, CancellationToken)

Expect and return a stream element during specified time or timeout.

Declaration
public T ExpectNext(TimeSpan? timeout, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
Nullable<TimeSpan> timeout
CancellationToken cancellationToken
Returns
Type Description
T
| Improve this Doc View Source

ExpectNext(Nullable<TimeSpan>, CancellationToken, T[])

Fluent DSL. Expect multiple stream elements.

Declaration
public TestSubscriber.ManualProbe<T> ExpectNext(TimeSpan? timeout, CancellationToken cancellationToken, params T[] elems)
Parameters
Type Name Description
Nullable<TimeSpan> timeout
CancellationToken cancellationToken
T[] elems
Returns
Type Description
TestSubscriber.ManualProbe<T>
| Improve this Doc View Source

ExpectNext(CancellationToken)

Expect and return a stream element.

Declaration
public T ExpectNext(CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
T
| Improve this Doc View Source

ExpectNext(CancellationToken, T[])

Fluent DSL. Expect multiple stream elements.

Declaration
public TestSubscriber.ManualProbe<T> ExpectNext(CancellationToken cancellationToken, params T[] elems)
Parameters
Type Name Description
CancellationToken cancellationToken
T[] elems
Returns
Type Description
TestSubscriber.ManualProbe<T>
| Improve this Doc View Source

ExpectNext<TOther>(Predicate<TOther>, CancellationToken)

Expect next element and test it with the predicate

Declaration
public TOther ExpectNext<TOther>(Predicate<TOther> predicate, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
Predicate<TOther> predicate

The System.Predicate{T} that is applied to the message
CancellationToken cancellationToken
Returns
Type Description
TOther

The next element
Type Parameters
Name Description
TOther

The System.Type of the expected message
| Improve this Doc View Source

ExpectNextAsync(T, CancellationToken)

Declaration
public async Task ExpectNextAsync(T element, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
T element
CancellationToken cancellationToken
Returns
Type Description
Task
| Improve this Doc View Source

ExpectNextAsync(T, TimeSpan, CancellationToken)

Expect a stream element.

Declaration
public async Task ExpectNextAsync(T element, TimeSpan timeout, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
T element
TimeSpan timeout
CancellationToken cancellationToken
Returns
Type Description
Task
| Improve this Doc View Source

ExpectNextAsync(Nullable<TimeSpan>, CancellationToken)

Expect and return a stream element during specified time or timeout.

Declaration
public async Task<T> ExpectNextAsync(TimeSpan? timeout, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
Nullable<TimeSpan> timeout
CancellationToken cancellationToken
Returns
Type Description
Task<T>
| Improve this Doc View Source

ExpectNextAsync(CancellationToken)

Expect and return a stream element.

Declaration
public async Task<T> ExpectNextAsync(CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
Task<T>
| Improve this Doc View Source

ExpectNextAsync<TOther>(Predicate<TOther>, CancellationToken)

Expect next element and test it with the predicate

Declaration
public async Task<TOther> ExpectNextAsync<TOther>(Predicate<TOther> predicate, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
Predicate<TOther> predicate

The System.Predicate{T} that is applied to the message
CancellationToken cancellationToken
Returns
Type Description
Task<TOther>

The next element
Type Parameters
Name Description
TOther

The System.Type of the expected message
| Improve this Doc View Source

ExpectNextN(IEnumerable<T>, Nullable<TimeSpan>, CancellationToken)

Fluent DSL. Expect the given elements to be signalled in order.

Declaration
public TestSubscriber.ManualProbe<T> ExpectNextN(IEnumerable<T> all, TimeSpan? timeout = null, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
IEnumerable<T> all
Nullable<TimeSpan> timeout
CancellationToken cancellationToken
Returns
Type Description
TestSubscriber.ManualProbe<T>
| Improve this Doc View Source

ExpectNextN(Int64, Nullable<TimeSpan>, CancellationToken)

Expect and return the next n stream elements.

Declaration
public IEnumerable<T> ExpectNextN(long n, TimeSpan? timeout = null, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
Int64 n
Nullable<TimeSpan> timeout
CancellationToken cancellationToken
Returns
Type Description
IEnumerable<T>
| Improve this Doc View Source

ExpectNextNAsync(IEnumerable<T>, Nullable<TimeSpan>, CancellationToken)

Expect the given elements to be signalled in order.

Declaration
public async Task ExpectNextNAsync(IEnumerable<T> all, TimeSpan? timeout = null, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
IEnumerable<T> all
Nullable<TimeSpan> timeout
CancellationToken cancellationToken
Returns
Type Description
Task
| Improve this Doc View Source

ExpectNextNAsync(Int64, Nullable<TimeSpan>, CancellationToken)

Expect and return the next n stream elements.

Declaration
public IAsyncEnumerable<T> ExpectNextNAsync(long n, TimeSpan? timeout = null, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
Int64 n
Nullable<TimeSpan> timeout
CancellationToken cancellationToken
Returns
Type Description
System.Collections.Generic.IAsyncEnumerable<T>
| Improve this Doc View Source

ExpectNextOrComplete(T, CancellationToken)

Fluent DSL. Expect given next element or stream completion.

Declaration
public TestSubscriber.ManualProbe<T> ExpectNextOrComplete(T element, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
T element
CancellationToken cancellationToken
Returns
Type Description
TestSubscriber.ManualProbe<T>
| Improve this Doc View Source

ExpectNextOrComplete(CancellationToken)

Expect given next element or stream completion, returning whichever was signaled.

Declaration
public object ExpectNextOrComplete(CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
Object
| Improve this Doc View Source

ExpectNextOrCompleteAsync(CancellationToken)

Expect given next element or stream completion, returning whichever was signaled.

Declaration
public async Task<object> ExpectNextOrCompleteAsync(CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
Task<Object>
| Improve this Doc View Source

ExpectNextOrError(T, Exception, CancellationToken)

Fluent DSL. Expect given next element or error signal.

Declaration
public TestSubscriber.ManualProbe<T> ExpectNextOrError(T element, Exception cause, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
T element
Exception cause
CancellationToken cancellationToken
Returns
Type Description
TestSubscriber.ManualProbe<T>
| Improve this Doc View Source

ExpectNextOrError(CancellationToken)

Expect given next element or error signal, returning whichever was signaled.

Declaration
public object ExpectNextOrError(CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
Object
| Improve this Doc View Source

ExpectNextOrErrorAsync(CancellationToken)

Expect given next element or error signal, returning whichever was signaled.

Declaration
public async Task<object> ExpectNextOrErrorAsync(CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
Task<Object>
| Improve this Doc View Source

ExpectNextUnordered(T[])

Fluent DSL. Expect multiple stream elements in arbitrary order.

Declaration
public TestSubscriber.ManualProbe<T> ExpectNextUnordered(params T[] elems)
Parameters
Type Name Description
T[] elems
Returns
Type Description
TestSubscriber.ManualProbe<T>
| Improve this Doc View Source

ExpectNextUnordered(Nullable<TimeSpan>, T[])

FluentDSL. Expect multiple stream elements in arbitrary order during specified timeout.

Declaration
[Obsolete("Use the method with CancellationToken support instead")]
public TestSubscriber.ManualProbe<T> ExpectNextUnordered(TimeSpan? timeout, params T[] elems)
Parameters
Type Name Description
Nullable<TimeSpan> timeout
T[] elems
Returns
Type Description
TestSubscriber.ManualProbe<T>
| Improve this Doc View Source

ExpectNextUnordered(Nullable<TimeSpan>, CancellationToken, T[])

FluentDSL. Expect multiple stream elements in arbitrary order during specified timeout.

Declaration
public TestSubscriber.ManualProbe<T> ExpectNextUnordered(TimeSpan? timeout, CancellationToken cancellationToken, params T[] elems)
Parameters
Type Name Description
Nullable<TimeSpan> timeout
CancellationToken cancellationToken
T[] elems
Returns
Type Description
TestSubscriber.ManualProbe<T>
| Improve this Doc View Source

ExpectNextUnordered(CancellationToken, T[])

FluentDSL. Expect multiple stream elements in arbitrary order.

Declaration
public TestSubscriber.ManualProbe<T> ExpectNextUnordered(CancellationToken cancellationToken, params T[] elems)
Parameters
Type Name Description
CancellationToken cancellationToken
T[] elems
Returns
Type Description
TestSubscriber.ManualProbe<T>
| Improve this Doc View Source

ExpectNextUnorderedN(IEnumerable<T>, Nullable<TimeSpan>, CancellationToken)

Fluent DSL. Expect the given elements to be signalled in any order.

Declaration
public TestSubscriber.ManualProbe<T> ExpectNextUnorderedN(IEnumerable<T> all, TimeSpan? timeout = null, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
IEnumerable<T> all
Nullable<TimeSpan> timeout
CancellationToken cancellationToken
Returns
Type Description
TestSubscriber.ManualProbe<T>
| Improve this Doc View Source

ExpectNextWithinSet(ICollection<T>, CancellationToken)

FluentDSL. Expect a single stream element matching one of the element in a list. Found element is removed from the list.

Declaration
public TestSubscriber.ManualProbe<T> ExpectNextWithinSet(ICollection<T> elems, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
ICollection<T> elems
CancellationToken cancellationToken
Returns
Type Description
TestSubscriber.ManualProbe<T>
| Improve this Doc View Source

ExpectNoMsg(CancellationToken)

Fluent DSL. Same as ExpectNoMsg(TimeSpan, CancellationToken), but correctly treating the timeFactor.

Declaration
public TestSubscriber.ManualProbe<T> ExpectNoMsg(CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
TestSubscriber.ManualProbe<T>
| Improve this Doc View Source

ExpectNoMsg(TimeSpan, CancellationToken)

Fluent DSL. Assert that no message is received for the specified time.

Declaration
public TestSubscriber.ManualProbe<T> ExpectNoMsg(TimeSpan remaining, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
TimeSpan remaining
CancellationToken cancellationToken
Returns
Type Description
TestSubscriber.ManualProbe<T>
| Improve this Doc View Source

ExpectNoMsgAsync(TimeSpan, CancellationToken)

Assert that no message is received for the specified time.

Declaration
public async Task ExpectNoMsgAsync(TimeSpan remaining, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
TimeSpan remaining
CancellationToken cancellationToken
Returns
Type Description
Task
| Improve this Doc View Source

ExpectSubscription(CancellationToken)

Expects and returns Reactive.Streams.ISubscription/>.

Declaration
public ISubscription ExpectSubscription(CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
Reactive.Streams.ISubscription
| Improve this Doc View Source

ExpectSubscriptionAndComplete(Boolean, CancellationToken)

Fluent DSL. Expect subscription followed by immediate stream completion. Depending on the signalDemand parameter demand may be signaled immediately after obtaining the subscription in order to wake up a possibly lazy upstream. You can disable this by setting the signalDemand parameter to false.

Declaration
public TestSubscriber.ManualProbe<T> ExpectSubscriptionAndComplete(bool signalDemand, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
Boolean signalDemand
CancellationToken cancellationToken
Returns
Type Description
TestSubscriber.ManualProbe<T>
See Also
| Improve this Doc View Source

ExpectSubscriptionAndComplete(CancellationToken)

Fluent DSL. Expect subscription followed by immediate stream completion. By default single demand will be signaled in order to wake up a possibly lazy upstream

Declaration
public TestSubscriber.ManualProbe<T> ExpectSubscriptionAndComplete(CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
TestSubscriber.ManualProbe<T>
See Also
| Improve this Doc View Source

ExpectSubscriptionAndCompleteAsync(Boolean, CancellationToken)

Declaration
public async Task ExpectSubscriptionAndCompleteAsync(bool signalDemand = true, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
Boolean signalDemand
CancellationToken cancellationToken
Returns
Type Description
Task
| Improve this Doc View Source

ExpectSubscriptionAndError(Boolean, CancellationToken)

Expect subscription to be followed immediately by an error signal. Depending on the signalDemand parameter demand may be signaled immediately after obtaining the subscription in order to wake up a possibly lazy upstream.You can disable this by setting the signalDemand parameter to false. ExpectSubscriptionAndError(CancellationToken)

Declaration
public Exception ExpectSubscriptionAndError(bool signalDemand, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
Boolean signalDemand
CancellationToken cancellationToken
Returns
Type Description
Exception
| Improve this Doc View Source

ExpectSubscriptionAndError(CancellationToken)

Expect subscription to be followed immediately by an error signal. By default single demand will be signaled in order to wake up a possibly lazy upstream. ExpectSubscriptionAndError(Boolean, CancellationToken)

Declaration
public Exception ExpectSubscriptionAndError(CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
Exception
| Improve this Doc View Source

ExpectSubscriptionAndErrorAsync(Boolean, CancellationToken)

Expect subscription to be followed immediately by an error signal. Depending on the signalDemand parameter demand may be signaled immediately after obtaining the subscription in order to wake up a possibly lazy upstream.You can disable this by setting the signalDemand parameter to false. ExpectSubscriptionAndError(CancellationToken)

Declaration
public async Task<Exception> ExpectSubscriptionAndErrorAsync(bool signalDemand, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
Boolean signalDemand
CancellationToken cancellationToken
Returns
Type Description
Task<Exception>
| Improve this Doc View Source

ExpectSubscriptionAndErrorAsync(CancellationToken)

Expect subscription to be followed immediately by an error signal. By default single demand will be signaled in order to wake up a possibly lazy upstream. ExpectSubscriptionAndError(Boolean, CancellationToken)

Declaration
public async Task<Exception> ExpectSubscriptionAndErrorAsync(CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
Task<Exception>
| Improve this Doc View Source

ExpectSubscriptionAsync(CancellationToken)

Expects and returns Reactive.Streams.ISubscription/>.

Declaration
public async Task<ISubscription> ExpectSubscriptionAsync(CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
Task<Reactive.Streams.ISubscription>
| Improve this Doc View Source

MatchNext<TOther>(Predicate<TOther>, CancellationToken)

Expect next element and test it with the predicate

Declaration
public TestSubscriber.ManualProbe<T> MatchNext<TOther>(Predicate<TOther> predicate, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
Predicate<TOther> predicate

The System.Predicate{T} that is applied to the message
CancellationToken cancellationToken
Returns
Type Description
TestSubscriber.ManualProbe<T>

this
Type Parameters
Name Description
TOther

The System.Type of the expected message
| Improve this Doc View Source

OnComplete()

Declaration
public void OnComplete()
| Improve this Doc View Source

OnError(Exception)

Declaration
public void OnError(Exception cause)
Parameters
Type Name Description
Exception cause
| Improve this Doc View Source

OnNext(T)

Declaration
public void OnNext(T element)
Parameters
Type Name Description
T element
| Improve this Doc View Source

OnSubscribe(ISubscription)

Declaration
public void OnSubscribe(ISubscription subscription)
Parameters
Type Name Description
Reactive.Streams.ISubscription subscription
| Improve this Doc View Source

ReceiveWhile<TOther>(Nullable<TimeSpan>, Nullable<TimeSpan>, Func<Object, TOther>, Int32, CancellationToken)

Receive messages for a given duration or until one does not match a given partial function.

Declaration
public IEnumerable<TOther> ReceiveWhile<TOther>(TimeSpan? max = null, TimeSpan? idle = null, Func<object, TOther> filter = null, int msgs = 2147483647, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
Nullable<TimeSpan> max
Nullable<TimeSpan> idle
Func<Object, TOther> filter
Int32 msgs
CancellationToken cancellationToken
Returns
Type Description
IEnumerable<TOther>
Type Parameters
Name Description
TOther
| Improve this Doc View Source

ReceiveWhileAsync<TOther>(Nullable<TimeSpan>, Nullable<TimeSpan>, Func<Object, TOther>, Int32, CancellationToken)

Receive messages for a given duration or until one does not match a given partial function.

Declaration
public IAsyncEnumerable<TOther> ReceiveWhileAsync<TOther>(TimeSpan? max = null, TimeSpan? idle = null, Func<object, TOther> filter = null, int msgs = 2147483647, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
Nullable<TimeSpan> max
Nullable<TimeSpan> idle
Func<Object, TOther> filter
Int32 msgs
CancellationToken cancellationToken
Returns
Type Description
System.Collections.Generic.IAsyncEnumerable<TOther>
Type Parameters
Name Description
TOther
| Improve this Doc View Source

ReceiveWithin<TOther>(Nullable<TimeSpan>, Int32, CancellationToken)

Drains a given number of messages

Declaration
public IEnumerable<TOther> ReceiveWithin<TOther>(TimeSpan? max, int messages = 2147483647, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
Nullable<TimeSpan> max
Int32 messages
CancellationToken cancellationToken
Returns
Type Description
IEnumerable<TOther>
Type Parameters
Name Description
TOther
| Improve this Doc View Source

ReceiveWithinAsync<TOther>(Nullable<TimeSpan>, Int32, CancellationToken)

Drains a given number of messages

Declaration
public IAsyncEnumerable<TOther> ReceiveWithinAsync<TOther>(TimeSpan? max, int messages = 2147483647, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
Nullable<TimeSpan> max
Int32 messages
CancellationToken cancellationToken
Returns
Type Description
System.Collections.Generic.IAsyncEnumerable<TOther>
Type Parameters
Name Description
TOther
| Improve this Doc View Source

ToStrict(TimeSpan, CancellationToken)

Attempt to drain the stream into a strict collection (by requesting long.MaxValue elements).

Declaration
public IList<T> ToStrict(TimeSpan atMost, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
TimeSpan atMost
CancellationToken cancellationToken
Returns
Type Description
IList<T>
Remarks

Use with caution: Be warned that this may not be a good idea if the stream is infinite or its elements are very large!

| Improve this Doc View Source

ToStrictAsync(TimeSpan, CancellationToken)

Attempt to drain the stream into a strict collection (by requesting long.MaxValue elements).

Declaration
public IAsyncEnumerable<T> ToStrictAsync(TimeSpan atMost, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
TimeSpan atMost
CancellationToken cancellationToken
Returns
Type Description
System.Collections.Generic.IAsyncEnumerable<T>
Remarks

Use with caution: Be warned that this may not be a good idea if the stream is infinite or its elements are very large!

| Improve this Doc View Source

Within<TOther>(TimeSpan, Func<TOther>, CancellationToken)

Sane as calling Within(TimeSpan.Zero, max, function).

Declaration
public TOther Within<TOther>(TimeSpan max, Func<TOther> execute, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
TimeSpan max
Func<TOther> execute
CancellationToken cancellationToken
Returns
Type Description
TOther
Type Parameters
Name Description
TOther
| Improve this Doc View Source

Within<TOther>(TimeSpan, TimeSpan, Func<TOther>, CancellationToken)

Execute code block while bounding its execution time between min and max. Within<TOther>(TimeSpan, TimeSpan, Func<TOther>, CancellationToken) blocks may be nested. All methods in this class which take maximum wait times are available in a version which implicitly uses the remaining time governed by the innermost enclosing Within<TOther>(TimeSpan, TimeSpan, Func<TOther>, CancellationToken) block.

Note that the timeout is scaled using Dilated(TimeSpan), which uses the configuration entry "akka.test.timefactor", while the min Duration is not.

var ret = probe.Within(Timespan.FromMilliseconds(50), () => { test.Tell("ping"); return ExpectMsg<string>(); });

Declaration
public TOther Within<TOther>(TimeSpan min, TimeSpan max, Func<TOther> execute, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
TimeSpan min
TimeSpan max
Func<TOther> execute
CancellationToken cancellationToken
Returns
Type Description
TOther
Type Parameters
Name Description
TOther
| Improve this Doc View Source

WithinAsync(TimeSpan, Func<Task>, Nullable<TimeSpan>, CancellationToken)

Declaration
public async Task WithinAsync(TimeSpan max, Func<Task> actionAsync, TimeSpan? epsilonValue = null, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
TimeSpan max
Func<Task> actionAsync
Nullable<TimeSpan> epsilonValue
CancellationToken cancellationToken
Returns
Type Description
Task
| Improve this Doc View Source

WithinAsync<TOther>(TimeSpan, Func<Task<TOther>>, CancellationToken)

Sane as calling WithinAsync(TimeSpan.Zero, max, function).

Declaration
public async Task<TOther> WithinAsync<TOther>(TimeSpan max, Func<Task<TOther>> execute, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
TimeSpan max
Func<Task<TOther>> execute
CancellationToken cancellationToken
Returns
Type Description
Task<TOther>
Type Parameters
Name Description
TOther
| Improve this Doc View Source

WithinAsync<TOther>(TimeSpan, TimeSpan, Func<Task<TOther>>, CancellationToken)

Declaration
public async Task<TOther> WithinAsync<TOther>(TimeSpan min, TimeSpan max, Func<Task<TOther>> execute, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
TimeSpan min
TimeSpan max
Func<Task<TOther>> execute
CancellationToken cancellationToken
Returns
Type Description
Task<TOther>
Type Parameters
Name Description
TOther

Implements

Reactive.Streams.ISubscriber<T>

Extension Methods