Class TestSubscriber.Probe<T>

Single subscription tracking for TestSubscriber.ManualProbe<T>.

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 Probe<T> : TestSubscriber.ManualProbe<T>, ISubscriber<T>
Type Parameters
Name Description
T

Methods

| Improve this Doc View Source

Cancel()

Declaration
public TestSubscriber.Probe<T> Cancel()
Returns
Type Description
TestSubscriber.Probe<T>
| Improve this Doc View Source

CancelAsync()

Declaration
public async Task CancelAsync()
Returns
Type Description
Task
| Improve this Doc View Source

EnsureSubscription(CancellationToken)

Ensure that the probe has received or will receive a subscription

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

EnsureSubscriptionAsync(CancellationToken)

Ensure that the probe has received or will receive a subscription

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

Request(Int64)

Declaration
public TestSubscriber.Probe<T> Request(long n)
Parameters
Type Name Description
Int64 n
Returns
Type Description
TestSubscriber.Probe<T>
| Improve this Doc View Source

RequestAsync(Int64)

Declaration
public async Task RequestAsync(long n)
Parameters
Type Name Description
Int64 n
Returns
Type Description
Task
| Improve this Doc View Source

RequestNext()

Request and expect a stream element.

Declaration
public T RequestNext()
Returns
Type Description
T
| Improve this Doc View Source

RequestNext(T)

Declaration
public TestSubscriber.Probe<T> RequestNext(T element)
Parameters
Type Name Description
T element
Returns
Type Description
TestSubscriber.Probe<T>
| Improve this Doc View Source

RequestNext(TimeSpan)

Request and expect a stream element during the specified time or timeout.

Declaration
public T RequestNext(TimeSpan timeout)
Parameters
Type Name Description
TimeSpan timeout
Returns
Type Description
T
| Improve this Doc View Source

RequestNextAsync()

Request and expect a stream element.

Declaration
public async Task<T> RequestNextAsync()
Returns
Type Description
Task<T>
| Improve this Doc View Source

RequestNextAsync(T)

Declaration
public async Task RequestNextAsync(T element)
Parameters
Type Name Description
T element
Returns
Type Description
Task
| Improve this Doc View Source

RequestNextAsync(TimeSpan)

Declaration
public async Task<T> RequestNextAsync(TimeSpan timeout)
Parameters
Type Name Description
TimeSpan timeout
Returns
Type Description
Task<T>

Implements

Reactive.Streams.ISubscriber<T>

Extension Methods