Interface INatsConnection

public interface INatsConnection : INatsClient, IAsyncDisposable

Inherited Members: INatsClient.Connection

INatsClient.ConnectAsync()

INatsClient.PingAsync(CancellationToken)

INatsClient.PublishAsync<T>(string, T, NatsHeaders, string, INatsSerialize<T>, NatsPubOpts, CancellationToken)

INatsClient.PublishAsync(string, NatsHeaders, string, NatsPubOpts, CancellationToken)

INatsClient.SubscribeAsync<T>(string, string, INatsDeserialize<T>, NatsSubOpts, CancellationToken)

INatsClient.RequestAsync<TRequest, TReply>(string, TRequest, NatsHeaders, INatsSerialize<TRequest>, INatsDeserialize<TReply>, NatsPubOpts, NatsSubOpts, CancellationToken)

INatsClient.RequestAsync<TReply>(string, INatsDeserialize<TReply>, NatsSubOpts, CancellationToken)

IAsyncDisposable.DisposeAsync()

Extension Methods: NatsRequestExtensions.RequestAsync<TRequest, TReply>(INatsConnection, in NatsMsg<TRequest>, INatsSerialize<TRequest>?, INatsDeserialize<TReply>?, NatsPubOpts?, NatsSubOpts?, CancellationToken)

NatsRequestManyExtensions.RequestManyAsync<TRequest, TReply>(INatsConnection, NatsMsg<TRequest>, INatsSerialize<TRequest>?, INatsDeserialize<TReply>?, NatsPubOpts?, NatsSubOpts?, CancellationToken)

Properties

NewInbox(): Create a new inbox subject with the form {Inbox Prefix}.{Unique Connection ID}.{Unique Inbox ID}

PublishAsync<T>(in NatsMsg<T>, INatsSerialize<T>?, NatsPubOpts?, CancellationToken): Publishes a serializable message payload to the given subject name, optionally supplying a reply subject.

RequestManyAsync<TRequest, TReply>(string, TRequest?, NatsHeaders?, INatsSerialize<TRequest>?, INatsDeserialize<TReply>?, NatsPubOpts?, NatsSubOpts?, CancellationToken): Request and receive zero or more replies from a responder.

SubscribeCoreAsync<T>(string, string?, INatsDeserialize<T>?, NatsSubOpts?, CancellationToken): Initiates a subscription to a subject, optionally joining a distributed queue group and returns a INatsSub<T> object which provides more control over the subscription.