From d467236f8ff719c2111afa4f8cd8d0da55bf8d01 Mon Sep 17 00:00:00 2001 From: Lars Lehtonen Date: Mon, 24 Feb 2020 05:49:27 -0800 Subject: [PATCH] broker/nats: remove unused setPublishOption() (#1234) broker/nats: remove unused setSubscribeOption() --- broker/nats/context.go | 20 -------------------- 1 file changed, 20 deletions(-) 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) - } -}