Class StreamTestKit.PublisherProbeSubscription<T>

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

Constructors

| Edit this page View Source

PublisherProbeSubscription(ISubscriber<T>, TestProbe)

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

Properties

| Edit this page View Source

PublisherProbe

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

Subscriber

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

Methods

| Edit this page View Source

Cancel()

Request the Reactive.Streams.IPublisher<T> to stop sending data and clean up resources.

Data may still be sent to meet previously signalled demand after calling cancel.

Declaration
public void Cancel()
| Edit this page View Source

ExpectCancellation(CancellationToken)

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

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

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

Request(long)

No events will be sent by a Reactive.Streams.IPublisher<T> until demand is signaled via this method.

It can be called however often and whenever needed—but the outstanding cumulative demand must never exceed MaxValue. An outstanding cumulative demand of MaxValue may be treated by the Reactive.Streams.IPublisher<T> as "effectively unbounded".

Whatever has been requested can be sent by the Reactive.Streams.IPublisher<T> so only signal demand for what can be safely handled.

A Reactive.Streams.IPublisher<T> can send less than is requested if the stream ends but then must emit either OnError(Exception) or Reactive.Streams.ISubscriber<T>.OnComplete().

Declaration
public void Request(long n)
Parameters
Type Name Description
long n

The strictly positive number of elements to requests to the upstream Reactive.Streams.IPublisher<T>
| Edit this page View Source

SendComplete()

Declaration
public void SendComplete()
| Edit this page View Source

SendError(Exception)

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

SendNext(T)

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

SendOnSubscribe()

Declaration
public void SendOnSubscribe()

Implements

Reactive.Streams.ISubscription

Extension Methods