Class ActorSubscriptionWithCursor<TIn>

TBD

Inheritance

Object

ActorSubscription<TIn>

ActorSubscriptionWithCursor<TIn>

Implements

IActorSubscription

Reactive.Streams.ISubscription

ICursor

Inherited Members

ActorSubscription<TIn>.Implementor

ActorSubscription<TIn>.Subscriber

ActorSubscription<TIn>.Request(Int64)

ActorSubscription<TIn>.Cancel()

Object.Equals(Object)

Object.Equals(Object, Object)

Object.GetHashCode()

Object.GetType()

Object.MemberwiseClone()

Object.ReferenceEquals(Object, Object)

Object.ToString()

Namespace: Akka.Streams.Implementation

Assembly: Akka.Streams.dll

Syntax

public class ActorSubscriptionWithCursor<TIn> : ActorSubscription<TIn>, IActorSubscription, ISubscription, ICursor

Type Parameters

Name	Description
TIn	TBD

Constructors

ActorSubscriptionWithCursor(IActorRef, ISubscriber<TIn>)

TBD

Declaration

public ActorSubscriptionWithCursor(IActorRef implementor, ISubscriber<TIn> subscriber)

Parameters

Type	Name	Description
IActorRef	implementor	TBD
Reactive.Streams.ISubscriber<TIn>	subscriber	TBD

Properties

Cursor

TBD

Declaration

public long Cursor { get; }

Property Value

Type	Description
Int64

IsActive

TBD

Declaration

public bool IsActive { get; }

Property Value

Type	Description
Boolean

TotalDemand

TBD

Declaration

public long TotalDemand { get; }

Property Value

Type	Description
Int64

Methods

Dispatch(TIn)

TBD

Declaration

public void Dispatch(TIn element)

Parameters

Type	Name	Description
TIn	element	TBD

Dispatch(Object)

TBD

Declaration

public void Dispatch(object element)

Parameters

Type	Name	Description
Object	element	TBD

Explicit Interface Implementations

ICursor.Cursor

Declaration

long ICursor.Cursor { get; set; }

Returns

Type	Description
Int64

Implements

IActorSubscription

Reactive.Streams.ISubscription

ICursor

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(Object)