Class CancelingSubscriber<T>

A subscriber who calls Reactive.Streams.ISubscription.Cancel() directly from OnSubscribe(ISubscription) and ignores all other callbacks.

Inheritance
Object
CancelingSubscriber<T>
Implements
Reactive.Streams.ISubscriber<T>
Inherited Members
Namespace: Akka.Streams.Implementation
Assembly: Akka.Streams.dll
Syntax
public sealed class CancelingSubscriber<T> : ISubscriber<T>
Type Parameters
Name Description
T

TBD

Fields

| Improve this Doc View Source

Instance

TBD

Declaration
public static readonly CancelingSubscriber<T> Instance
Field Value
Type Description
CancelingSubscriber<T>

Methods

| Improve this Doc View Source

OnComplete()

TBD

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

OnError(Exception)

TBD

Declaration
public void OnError(Exception cause)
Parameters
Type Name Description
Exception cause

TBD
| Improve this Doc View Source

OnNext(T)

TBD

Declaration
public void OnNext(T element)
Parameters
Type Name Description
T element

TBD
| Improve this Doc View Source

OnSubscribe(ISubscription)

TBD

Declaration
public void OnSubscribe(ISubscription subscription)
Parameters
Type Name Description
Reactive.Streams.ISubscription subscription

TBD

Implements

Reactive.Streams.ISubscriber<T>

Extension Methods