diff --git a/broker/nats/context.go b/broker/nats/context.go index d4c1a3b0..8284b557 100644 --- a/broker/nats/context.go +++ b/broker/nats/context.go @@ -6,16 +6,6 @@ import ( "github.com/micro/go-micro/v2/broker" ) -// setSubscribeOption returns a function to setup a context with given value -func setSubscribeOption(k, v interface{}) broker.SubscribeOption { - return func(o *broker.SubscribeOptions) { - if o.Context == nil { - o.Context = context.Background() - } - o.Context = context.WithValue(o.Context, k, v) - } -} - // setBrokerOption returns a function to setup a context with given value func setBrokerOption(k, v interface{}) broker.Option { return func(o *broker.Options) { @@ -25,13 +15,3 @@ func setBrokerOption(k, v interface{}) broker.Option { o.Context = context.WithValue(o.Context, k, v) } } - -// setPublishOption returns a function to setup a context with given value -func setPublishOption(k, v interface{}) broker.PublishOption { - return func(o *broker.PublishOptions) { - if o.Context == nil { - o.Context = context.Background() - } - o.Context = context.WithValue(o.Context, k, v) - } -}