Struct FanIn<T>.SubInput
TBD
Implements
ISubscriber<T>
Inherited Members
Namespace: Akka.Streams.Implementation
Assembly: Akka.Streams.dll
Syntax
public readonly struct FanIn<T>.SubInput : ISubscriber<T>
Constructors
| Edit this page View SourceSubInput(IActorRef, int)
TBD
Declaration
public SubInput(IActorRef impl, int id)
Parameters
Type | Name | Description |
---|---|---|
IActorRef | impl | TBD |
int | id | TBD |
Methods
| Edit this page View SourceOnComplete()
TBD
Declaration
public void OnComplete()
OnError(Exception)
TBD
Declaration
public void OnError(Exception cause)
Parameters
Type | Name | Description |
---|---|---|
Exception | cause | TBD |
OnNext(T)
TBD
Declaration
public void OnNext(T element)
Parameters
Type | Name | Description |
---|---|---|
T | element | TBD |
OnSubscribe(ISubscription)
TBD
Declaration
public void OnSubscribe(ISubscription subscription)
Parameters
Type | Name | Description |
---|---|---|
ISubscription | subscription | TBD |
Implements
Reactive.Streams.ISubscriber<T>