unistack-org/micro
4
0
Fork 3
Code Issues 17 Pull Requests 1 Actions 1 Packages Projects Releases 258 Wiki Activity

broker/nats: remove unused setPublishOption() (#1234)

Browse Source 
broker/nats: remove unused setSubscribeOption()
This commit is contained in:
Lars Lehtonen 2020-02-24 05:49:27 -08:00 committed by GitHub
parent 24d574ae71
commit d467236f8f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 0 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
broker/nats/context.go
View File

@ -6,16 +6,6 @@ import (
"github.com/micro/go-micro/v2/broker" "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 // setBrokerOption returns a function to setup a context with given value
func setBrokerOption(k, v interface{}) broker.Option { func setBrokerOption(k, v interface{}) broker.Option {
return func(o *broker.Options) { return func(o *broker.Options) {
@ -25,13 +15,3 @@ func setBrokerOption(k, v interface{}) broker.Option {
o.Context = context.WithValue(o.Context, k, v) 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)
}
}