From ad51f45871bb25c6aaa68797be82187c859d7134 Mon Sep 17 00:00:00 2001 From: Sinh Date: Thu, 25 Aug 2022 16:57:42 +0700 Subject: [PATCH] add request json encode --- json_encoder.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/json_encoder.go b/json_encoder.go index 4a0bdb8..af13573 100644 --- a/json_encoder.go +++ b/json_encoder.go @@ -26,3 +26,8 @@ func (e JSONEncoder) Subscribe(subject string, cb nats.Handler) (*nats.Subscript func (e JSONEncoder) Publish(reply string, data interface{}) error { return e.encConn.Publish(reply, data) } + +// Request ... +func (e JSONEncoder) Request(subject string, data interface{}, res interface{}) error { + return e.encConn.Request(subject, data, res, requestTimeout) +}