Class NatsSubBase

Namespace

NATS.Client.Core

Assembly

NATS.Client.Core.dll

public abstract class NatsSubBase

Inheritance

object

NatsSubBase

Derived

NatsSub<T>

NatsSvcEndpointBase

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Properties

Connection

EndReason

Exception

PendingMsgs

QueueGroup

If specified, the subscriber will join this queue group. Subscribers with the same queue group name, become a queue group, and only one randomly chosen subscriber of the queue group will consume a message each time a message is received by the queue group.

Subject

The subject name to subscribe to.

Methods

DecrementMaxMsgs()

DisposeAsync()

EndSubscription(NatsSubEndReason)

ReadyAsync()

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

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.

ResetIdleTimeout()

SetException(Exception)

TryComplete()

Invoked to signal end of the subscription.

UnsubscribeAsync()

Complete the message channel, stop timers if they were used and send an unsubscribe message to the server.