Struct FanIn<T>.SubInput

TBD

Implements

Reactive.Streams.ISubscriber<T>

Inherited Members

ValueType.Equals(Object)

ValueType.GetHashCode()

ValueType.ToString()

Object.Equals(Object, Object)

Object.GetType()

Object.ReferenceEquals(Object, Object)

Namespace: Akka.Streams.Implementation

Assembly: Akka.Streams.dll

Syntax

public readonly struct SubInput : ISubscriber<T>

Constructors

SubInput(IActorRef, Int32)

TBD

Declaration

public SubInput(IActorRef impl, int id)

Parameters

Type	Name	Description
IActorRef	impl	TBD
Int32	id	TBD

Methods

OnComplete()

TBD

Declaration

public readonly void OnComplete()

OnError(Exception)

TBD

Declaration

public readonly void OnError(Exception cause)

Parameters

Type	Name	Description
Exception	cause	TBD

OnNext(T)

TBD

Declaration

public readonly void OnNext(T element)

Parameters

Type	Name	Description
T	element	TBD

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

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(Object)