Class NatsSub<T>

Namespace

NATS.Client.Core

Assembly

NATS.Client.Core.dll

public sealed class NatsSub<T> : NatsSubBase, INatsSub<T>, IAsyncDisposable

Type Parameters

T

Inheritance

object

NatsSubBase

NatsSub<T>

Implements

INatsSub<T>

IAsyncDisposable

Inherited Members

NatsSubBase.Subject

NatsSubBase.QueueGroup

NatsSubBase.Exception

NatsSubBase.PendingMsgs

NatsSubBase.EndReason

NatsSubBase.ReadyAsync()

NatsSubBase.UnsubscribeAsync()

NatsSubBase.DisposeAsync()

NatsSubBase.ReceiveAsync(string, string, ReadOnlySequence<byte>?, ReadOnlySequence<byte>)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

NatsSub(INatsConnection, INatsSubscriptionManager, string, string?, NatsSubOpts?, INatsDeserialize<T>, CancellationToken)

Properties

Msgs

Access incoming messages for your subscription.

Methods

ReceiveInternalAsync(string, string?, ReadOnlySequence<byte>?, ReadOnlySequence<byte>)

Invoked when a MSG or HMSG arrives for the subscription. This method is invoked while reading from the socket. Buffers belong to the socket reader and you should process them as quickly as possible or create a copy before you return from this method.

TryComplete()

Invoked to signal end of the subscription.