From 76996c81422bb3c3f22cc06dc19fb4a37d7613d1 Mon Sep 17 00:00:00 2001 From: Nam Huynh Date: Fri, 18 Mar 2022 11:24:12 +0700 Subject: [PATCH] done add pull sub --- natsio.go | 11 ----------- 1 file changed, 11 deletions(-) diff --git a/natsio.go b/natsio.go index 23a3903..33bdbb2 100644 --- a/natsio.go +++ b/natsio.go @@ -21,9 +21,6 @@ type JetStream struct { var ( natsServer Server natsJetStream JetStream - - // FIXME: delete this - jsPublic nats.JetStreamContext ) // Connect ... @@ -65,9 +62,6 @@ func Connect(cfg Config) error { } natsJetStream.instance = js - // FIXME: delete this - jsPublic = js - return nil } @@ -80,8 +74,3 @@ func GetServer() Server { func GetJetStream() JetStream { return natsJetStream } - -// GetJSPublic ... -func GetJSPublic() nats.JetStreamContext { - return jsPublic -}