diff --git a/client.go b/client.go index ae367f9..39f3bb7 100644 --- a/client.go +++ b/client.go @@ -199,7 +199,7 @@ func (c *Client) run() { } // broadcast the shutdown error to the remaining waiters. for _, waiter := range waiters { - waiter.errs <- shutdownErr + waiter.errs <- c.err } return }