From a78a78fffa2b169dd473b512d38d1fdd8c25c665 Mon Sep 17 00:00:00 2001 From: Nam Huynh Date: Wed, 13 Oct 2021 14:53:16 +0700 Subject: [PATCH] return subscription instance --- pubsub.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/pubsub.go b/pubsub.go index c130250..915a66b 100644 --- a/pubsub.go +++ b/pubsub.go @@ -22,13 +22,13 @@ func Publish(stream, subject string, data interface{}) error { } // Subscribe ... -func Subscribe(stream, subject string, cb nats.MsgHandler) error { +func Subscribe(stream, subject string, cb nats.MsgHandler) (*nats.Subscription, error) { channel := combineStreamAndSubjectName(stream, subject) - _, err := natsJS.Subscribe(channel, cb) + sub, err := natsJS.Subscribe(channel, cb) if err != nil { msg := fmt.Sprintf("subscribe subject %s error: %s", channel, err.Error()) - return errors.New(msg) + return nil, errors.New(msg) } - return nil + return sub, nil }