Method wrapContextWithoutDeadline

jetstream/jetstream.go:1258–1263

wrapContextWithoutDeadline wraps context without deadline with default timeout. If deadline is already set, it will be returned as is, and cancel() will be nil. Caller should check if cancel() is nil before calling it.

(ctx context.Context)

// If deadline is already set, it will be returned as is, and cancel() will be nil.
// Caller should check if cancel() is nil before calling it.
func (js *jetStream) wrapContextWithoutDeadline(ctx context.Context) (context.Context, context.CancelFunc) {
	if _, ok := ctx.Deadline(); ok {
		return ctx, nil
	}
	return context.WithTimeout(ctx, js.opts.DefaultTimeout)
}

// CleanupPublisher will cleanup the publishing side of JetStreamContext.
//