Class ActorSubscriptionWithCursor<TIn>

TBD

Inheritance

object

ActorSubscription<TIn>

ActorSubscriptionWithCursor<TIn>

Implements

IActorSubscription

ISubscription

ICursor

Inherited Members

ActorSubscription<TIn>.Implementor

ActorSubscription<TIn>.Subscriber

ActorSubscription<TIn>.Request(long)

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
ISubscriber<TIn>	subscriber	TBD

Properties

Cursor

TBD

Declaration

public long Cursor { get; }

Property Value

Type	Description
long

IsActive

TBD

Declaration

public bool IsActive { get; }

Property Value

Type	Description
bool

TotalDemand

TBD

Declaration

public long TotalDemand { get; }

Property Value

Type	Description
long

Methods

Dispatch(object)

TBD

Declaration

public void Dispatch(object element)

Parameters

Type	Name	Description
object	element	TBD

Dispatch(TIn)

TBD

Declaration

public void Dispatch(TIn element)

Parameters

Type	Name	Description
TIn	element	TBD

Implements

IActorSubscription

Reactive.Streams.ISubscription

ICursor

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(object)