returns nats.msghandler type

go-kit · May 18, 2022 · 4fe72fe · 4fe72fe
1 parent d7cefca
commit 4fe72fe
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/transport/nats/subscriber.go b/transport/nats/subscriber.go
@@ -91,7 +91,7 @@ func SubscriberFinalizer(f ...SubscriberFinalizerFunc) SubscriberOption {
 }
 
 // ServeMsg provides nats.MsgHandler.
-func (s Subscriber) ServeMsg(nc *nats.Conn) func(msg *nats.Msg) {
+func (s Subscriber) ServeMsg(nc *nats.Conn) nats.MsgHandler {
 	return func(msg *nats.Msg) {
 		ctx, cancel := context.WithCancel(context.Background())
 		defer cancel()