Skip to content

Commit 795db74

Browse files
committed
test: fix flaky test
Closes #514
1 parent 6a24a64 commit 795db74

File tree

1 file changed

+2
-6
lines changed

1 file changed

+2
-6
lines changed

connection.go

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1485,9 +1485,7 @@ func (conn *Connection) newWatcherImpl(key string, callback WatchCallback) (Watc
14851485
// request will not be finished by a small per-request
14861486
// timeout.
14871487
req := newWatchRequest(key).Context(context.Background())
1488-
if _, err = conn.Do(req).Get(); err != nil {
1489-
return
1490-
}
1488+
_, _ = conn.Do(req).Get()
14911489
}
14921490
}
14931491

@@ -1510,9 +1508,7 @@ func (conn *Connection) newWatcherImpl(key string, callback WatchCallback) (Watc
15101508
// not be finished by a small per-request timeout to
15111509
// avoid lost of the request.
15121510
req := newUnwatchRequest(key).Context(context.Background())
1513-
if _, err = conn.Do(req).Get(); err != nil {
1514-
return
1515-
}
1511+
_, err = conn.Do(req).Get()
15161512
}
15171513
conn.watchMap.Delete(key)
15181514
close(state.unready)

0 commit comments

Comments
 (0)