Class ActorSubscriberImpl<T>

TBD

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

TBD

Constructors

| Improve this Doc View Source

ActorSubscriberImpl(IActorRef)

TBD

Declaration
public ActorSubscriberImpl(IActorRef impl)
Parameters
Type Name Description
IActorRef impl

TBD
Exceptions
Type Condition
ArgumentNullException

This exception is thrown when the specified impl is undefined.

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
Exceptions
Type Condition
ArgumentNullException

This exception is thrown when the specified cause is undefined.
| 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

OnNext(Object)

TBD

Declaration
public void OnNext(object element)
Parameters
Type Name Description
Object element

TBD
Exceptions
Type Condition
ArgumentNullException

This exception is thrown when the specified element is undefined.
| Improve this Doc View Source

OnSubscribe(ISubscription)

TBD

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

TBD
Exceptions
Type Condition
ArgumentNullException

This exception is thrown when the specified subscription is undefined.

Implements

Reactive.Streams.ISubscriber<T>

Extension Methods