unistack-org/micro-broker-nats
4
0
Fork 1
Code Issues 2 Pull Requests Actions Packages Projects Releases 8 Wiki Activity

Revert "Use Drain() to unsuscribe or close connection"

Browse Source 
This reverts commit 4d5859307ddbcc3c6af907ba0d0fac395b466836.
This commit is contained in:
magodo 2019-05-15 14:39:06 +08:00 committed by Vasiliy Tolstov
parent e2254ba411
commit 20453c885d
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
nats.go
View File

@ -56,7 +56,7 @@ func (n *subscriber) Topic() string {
} }
func (n *subscriber) Unsubscribe() error { func (n *subscriber) Unsubscribe() error {
return n.s.Drain() return n.s.Unsubscribe()
} }
func (n *nbroker) Address() string { func (n *nbroker) Address() string {
@ -121,7 +121,7 @@ func (n *nbroker) Connect() error {
func (n *nbroker) Disconnect() error { func (n *nbroker) Disconnect() error {
n.RLock() n.RLock()
n.conn.Drain() n.conn.Close()
n.RUnlock() n.RUnlock()
return nil return nil
} }