From 203486fd31dad93b67f68d425a3959a6544556b0 Mon Sep 17 00:00:00 2001
From: Asim Aslam <asim@aslam.me>
Date: Thu, 13 Feb 2020 22:34:56 +0000
Subject: [PATCH] check for etcd watcher canceled value

---
 registry/etcd/watcher.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/registry/etcd/watcher.go b/registry/etcd/watcher.go
index fdf2ea58..b8ce443d 100644
--- a/registry/etcd/watcher.go
+++ b/registry/etcd/watcher.go
@@ -48,6 +48,9 @@ func (ew *etcdWatcher) Next() (*registry.Result, error) {
 		if wresp.Err() != nil {
 			return nil, wresp.Err()
 		}
+		if wresp.Canceled {
+			return nil, errors.New("could not get next")
+		}
 		for _, ev := range wresp.Events {
 			service := decode(ev.Kv.Value)
 			var action string