Class TestSubscriber.Probe<T>

Single subscription tracking for TestSubscriber.ManualProbe<T>.

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

Methods

| Edit this page View Source

Cancel()

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

CancelAsync()

Declaration
public Task CancelAsync()
Returns
Type Description
Task
| Edit this page View Source

EnsureSubscription(CancellationToken)

Ensure that the probe has received or will receive a subscription

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

EnsureSubscriptionAsync(CancellationToken)

Ensure that the probe has received or will receive a subscription

Declaration
public Task EnsureSubscriptionAsync(CancellationToken cancellationToken = default)
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
Task
| Edit this page View Source

Request(long)

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

RequestAsync(long)

Declaration
public Task RequestAsync(long n)
Parameters
Type Name Description
long n
Returns
Type Description
Task
| Edit this page View Source

RequestNext()

Request and expect a stream element.

Declaration
public T RequestNext()
Returns
Type Description
T
| Edit this page 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
| Edit this page View Source

RequestNext(T)

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

RequestNextAsync()

Request and expect a stream element.

Declaration
public Task<T> RequestNextAsync()
Returns
Type Description
Task<T>
| Edit this page View Source

RequestNextAsync(TimeSpan)

Declaration
public Task<T> RequestNextAsync(TimeSpan timeout)
Parameters
Type Name Description
TimeSpan timeout
Returns
Type Description
Task<T>
| Edit this page View Source

RequestNextAsync(T)

Declaration
public Task RequestNextAsync(T element)
Parameters
Type Name Description
T element
Returns
Type Description
Task

Implements

Reactive.Streams.ISubscriber<T>

Extension Methods