Class StreamTestKit.CompletedSubscription<T>

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

Constructors

| Edit this page View Source

CompletedSubscription(ISubscriber<T>)

Declaration
public CompletedSubscription(ISubscriber<T> subscriber)
Parameters
Type Name Description
ISubscriber<T> subscriber

Properties

| 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

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>

Implements

Reactive.Streams.ISubscription

Extension Methods