code: func (sub *ClientSubscription) Unsubscribe() {
  	sub.quitWithError(nil, true)
  	sub.errOnce.Do(func() { close(sub.err) })
  }
docs: // Unsubscribe unsubscribes the notification and closes the error channel.
  // It can safely be called more than once.