diff --git a/subscription.go b/subscription.go index 56128af..5db1cb8 100644 --- a/subscription.go +++ b/subscription.go @@ -49,7 +49,7 @@ func (sub *Subscription) Cancel() { sub.cancelCh <- sub } -func (sub *Subscription) close(){ +func (sub *Subscription) close() { close(sub.ch) close(sub.joinCh) close(sub.leaveCh)