diff --git a/nats.go b/nats.go index 5acba41..b4da34c 100644 --- a/nats.go +++ b/nats.go @@ -56,7 +56,7 @@ func (n *subscriber) Topic() string { } func (n *subscriber) Unsubscribe() error { - return n.s.Drain() + return n.s.Unsubscribe() } func (n *nbroker) Address() string { @@ -121,7 +121,7 @@ func (n *nbroker) Connect() error { func (n *nbroker) Disconnect() error { n.RLock() - n.conn.Drain() + n.conn.Close() n.RUnlock() return nil }