Function WithPublishAsyncTimeout

jetstream/jetstream_options.go:62–67

WithPublishAsyncTimeout sets the timeout for async message publish. If not provided, timeout is disabled.

(dur time.Duration)

// WithPublishAsyncTimeout sets the timeout for async message publish.
// If not provided, timeout is disabled.
func WithPublishAsyncTimeout(dur time.Duration) JetStreamOpt {
	return func(opts *JetStreamOptions) error {
		opts.publisherOpts.ackTimeout = dur
		return nil
	}
}

// WithDefaultTimeout sets the default timeout for JetStream API requests.
// It is used when context used for the request does not have a deadline set.