returns nats.msghandler type

Ali Sunjaya · Ali Sunjaya · commit 4fe72fe7b347 · 2022-05-19T00:39:10.000+07:00
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()

Original file line number	Diff line number	Diff line change
`@@ -91,7 +91,7 @@ func SubscriberFinalizer(f ...SubscriberFinalizerFunc) SubscriberOption {`
`91`	`91`	`}`
`92`	`92`
`93`	`93`	`// ServeMsg provides nats.MsgHandler.`
`94`		`-func (s Subscriber) ServeMsg(nc nats.Conn) func(msg nats.Msg) {`
	`94`	`+func (s Subscriber) ServeMsg(nc *nats.Conn) nats.MsgHandler {`
`95`	`95`	`return func(msg *nats.Msg) {`
`96`	`96`	`ctx, cancel := context.WithCancel(context.Background())`
`97`	`97`	`defer cancel()`