From 85e03cbab7ebc6fe5bafce2eb1126c544b80c058 Mon Sep 17 00:00:00 2001 From: Ali Sunjaya Date: Thu, 19 May 2022 00:39:10 +0700 Subject: [PATCH] returns nats.msghandler type --- transport/nats/subscriber.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/transport/nats/subscriber.go b/transport/nats/subscriber.go index d4b5adcb6..23e3c5ec0 100644 --- 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()