Class TestPublisher.Probe<T>

Single subscription and demand tracking for TestPublisher.ManualProbe<T>.

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

Properties

| Improve this Doc View Source

Pending

Current pending requests.

Declaration
public long Pending { get; }
Property Value
Type Description
Int64

Methods

| Improve this Doc View Source

EnsureSubscription(CancellationToken)

Asserts that a subscription has been received or will be received

Declaration
public void EnsureSubscription(CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
CancellationToken cancellationToken
| Improve this Doc View Source

EnsureSubscriptionAsync(CancellationToken)

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

ExpectCancellation(CancellationToken)

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

ExpectCancellationAsync(CancellationToken)

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

ExpectRequest(CancellationToken)

Declaration
public long ExpectRequest(CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
Int64
| Improve this Doc View Source

ExpectRequestAsync(CancellationToken)

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

SendComplete(CancellationToken)

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

SendCompleteAsync(CancellationToken)

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

SendError(Exception, CancellationToken)

Declaration
public TestPublisher.Probe<T> SendError(Exception e, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
Exception e
CancellationToken cancellationToken
Returns
Type Description
TestPublisher.Probe<T>
| Improve this Doc View Source

SendErrorAsync(Exception, CancellationToken)

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

SendNext(T, CancellationToken)

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

SendNextAsync(T, CancellationToken)

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

UnsafeSendNext(T, CancellationToken)

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

UnsafeSendNextAsync(T, CancellationToken)

Declaration
public async Task UnsafeSendNextAsync(T element, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
T element
CancellationToken cancellationToken
Returns
Type Description
Task

Implements

Reactive.Streams.IPublisher<T>

Extension Methods