Class TestPublisher.Probe<T>

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

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

Properties

| Edit this page View Source

Pending

Current pending requests.

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

Methods

| Edit this page View Source

EnsureSubscription(CancellationToken)

Asserts that a subscription has been received or will be received

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

EnsureSubscriptionAsync(CancellationToken)

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

ExpectCancellation(CancellationToken)

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

ExpectCancellationAsync(CancellationToken)

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

ExpectRequest(CancellationToken)

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

ExpectRequestAsync(CancellationToken)

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

SendComplete(CancellationToken)

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

SendCompleteAsync(CancellationToken)

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

SendError(Exception, CancellationToken)

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

SendErrorAsync(Exception, CancellationToken)

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

SendNext(T, CancellationToken)

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

SendNextAsync(T, CancellationToken)

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

UnsafeSendNext(T, CancellationToken)

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

UnsafeSendNextAsync(T, CancellationToken)

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

Implements

Reactive.Streams.IPublisher<T>

Extension Methods