Class NatsJSConsumer

Namespace

NATS.Client.JetStream

Assembly

NATS.Client.JetStream.dll

Represents a NATS JetStream consumer.

public class NatsJSConsumer : INatsJSConsumer

Inheritance

object

NatsJSConsumer

Implements

INatsJSConsumer

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Properties

Info

Consumer info object as retrieved from NATS JetStream server at the time this object was created, updated or refreshed.

Methods

ConsumeAsync<T>(INatsDeserialize<T>?, NatsJSConsumeOpts?, CancellationToken)

Starts an enumerator consuming messages from the stream using this consumer.

DeleteAsync(CancellationToken)

Delete this consumer.

FetchAsync<T>(NatsJSFetchOpts, INatsDeserialize<T>?, CancellationToken)

Consume a set number of messages from the stream using this consumer.

FetchNoWaitAsync<T>(NatsJSFetchOpts, INatsDeserialize<T>?, CancellationToken)

Consume a set number of messages from the stream using this consumer. Returns immediately if no messages are available.

NextAsync<T>(INatsDeserialize<T>?, NatsJSNextOpts?, CancellationToken)

Consume a single message from the stream using this consumer.

RefreshAsync(CancellationToken)

Retrieve the consumer info from the server and update this consumer.