From 7b2f769643a1cd4478e33a277c644d91b8686aba Mon Sep 17 00:00:00 2001
From: Anthony Romano <anthony.romano@coreos.com>
Date: Thu, 1 Sep 2016 15:22:35 -0700
Subject: [PATCH] clientv3: only resume watcher if error is non-halting

---
 clientv3/watch.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/clientv3/watch.go b/clientv3/watch.go
index 6dd149057..6efd56487 100644
--- a/clientv3/watch.go
+++ b/clientv3/watch.go
@@ -477,7 +477,7 @@ func (w *watchGrpcStream) run() {
 		// watch client failed to recv; spawn another if possible
 		// TODO report watch client errors from errc?
 		case err := <-w.errc:
-			if toErr(w.ctx, err) == v3rpc.ErrNoLeader {
+			if isHaltErr(w.ctx, err) || toErr(w.ctx, err) == v3rpc.ErrNoLeader {
 				closeErr = err
 				return
 			}