Class StreamTestKit.PublisherProbeSubscription<T>

Inheritance
Object
StreamTestKit.PublisherProbeSubscription<T>
Implements
Reactive.Streams.ISubscription
Inherited Members
Namespace: Akka.Streams.TestKit
Assembly: Akka.Streams.TestKit.dll
Syntax
public sealed class PublisherProbeSubscription<T> : ISubscription
Type Parameters
Name Description
T

Constructors

| Improve this Doc View Source

PublisherProbeSubscription(ISubscriber<T>, TestProbe)

Declaration
public PublisherProbeSubscription(ISubscriber<T> subscriber, TestProbe publisherProbe)
Parameters
Type Name Description
Reactive.Streams.ISubscriber<T> subscriber
TestProbe publisherProbe

Properties

| Improve this Doc View Source

PublisherProbe

Declaration
public TestProbe PublisherProbe { get; }
Property Value
Type Description
TestProbe
| Improve this Doc View Source

Subscriber

Declaration
public ISubscriber<T> Subscriber { get; }
Property Value
Type Description
Reactive.Streams.ISubscriber<T>

Methods

| Improve this Doc View Source

Cancel()

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

ExpectCancellation(CancellationToken)

Declaration
public void ExpectCancellation(CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
CancellationToken cancellationToken
| 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(Int64, CancellationToken)

Declaration
public void ExpectRequest(long n, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
Int64 n
CancellationToken cancellationToken
| 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(Int64, CancellationToken)

Declaration
public async Task ExpectRequestAsync(long n, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
Int64 n
CancellationToken cancellationToken
Returns
Type Description
Task
| 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

Request(Int64)

Declaration
public void Request(long n)
Parameters
Type Name Description
Int64 n
| Improve this Doc View Source

SendComplete()

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

SendError(Exception)

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

SendNext(T)

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

SendOnSubscribe()

Declaration
public void SendOnSubscribe()

Implements

Reactive.Streams.ISubscription

Extension Methods