Struct FanIn<T>.SubInput

TBD

Implements
Reactive.Streams.ISubscriber<T>
Inherited Members
Namespace: Akka.Streams.Implementation
Assembly: Akka.Streams.dll
Syntax
public readonly struct SubInput : ISubscriber<T>

Constructors

| Improve this Doc View Source

SubInput(IActorRef, Int32)

TBD

Declaration
public SubInput(IActorRef impl, int id)
Parameters
Type Name Description
IActorRef impl

TBD
Int32 id

TBD

Methods

| Improve this Doc View Source

OnComplete()

TBD

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

OnError(Exception)

TBD

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

TBD
| Improve this Doc View Source

OnNext(T)

TBD

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

TBD
| Improve this Doc View Source

OnSubscribe(ISubscription)

TBD

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

TBD

Implements

Reactive.Streams.ISubscriber<T>

Extension Methods