Method CreatePushConsumerAsync

Namespace

NATS.Client.JetStream

Assembly

NATS.Client.JetStream.dll

CreatePushConsumerAsync(NatsJSPushConsumerOpts?, CancellationToken)

Creates a new push consumer on this stream.

ValueTask<INatsJSPushConsumer> CreatePushConsumerAsync(NatsJSPushConsumerOpts? opts = null, CancellationToken cancellationToken = default)

Parameters

opts NatsJSPushConsumerOpts

Push consumer options.

cancellationToken CancellationToken

A CancellationToken used to cancel the API call.

Returns

ValueTask<INatsJSPushConsumer>

The NATS JetStream push consumer object.