Method PublishConcurrentAsync

Namespace

NATS.Client.JetStream

Assembly

NATS.Client.JetStream.dll

PublishConcurrentAsync<T>(string, T?, INatsSerialize<T>?, NatsJSPubOpts?, NatsHeaders?, CancellationToken)

public ValueTask<NatsJSPublishConcurrentFuture> PublishConcurrentAsync<T>(string subject, T? data, INatsSerialize<T>? serializer = null, NatsJSPubOpts? opts = null, NatsHeaders? headers = null, CancellationToken cancellationToken = default)

Parameters

subject string

data T

serializer INatsSerialize<T>

opts NatsJSPubOpts

headers NatsHeaders

cancellationToken CancellationToken

Returns

ValueTask<NatsJSPublishConcurrentFuture>

Type Parameters

T