Skip to content

Commit

Permalink
fix format
Browse files Browse the repository at this point in the history
  • Loading branch information
wongoo committed Nov 18, 2019
1 parent dc7f281 commit 01b177b
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 0 deletions.
1 change: 1 addition & 0 deletions watcher.go
Original file line number Diff line number Diff line change
Expand Up @@ -115,6 +115,7 @@ func (w *Watcher) Watch() {
case <-w.client.done:
logger.Debugf("zk watcher [%s] exit for client closed", path)
w.Close()

return
case <-w.done:
logger.Debugf("zk watcher [%s] exit for watcher closed", path)
Expand Down
1 change: 1 addition & 0 deletions zkclient.go
Original file line number Diff line number Diff line change
Expand Up @@ -62,6 +62,7 @@ func NewClient(servers []string, options ...ClientOption) *Client {
func (cli *Client) startConnMaintainer() {
go func() {
ticker := time.NewTicker(time.Second * 20)

for {
select {
case <-cli.done:
Expand Down

0 comments on commit 01b177b

Please sign in to comment.