From 68b1e9f728ba1d0a823a96efe1e9b58dc1d42eb6 Mon Sep 17 00:00:00 2001
From: yangxuanjia <yangxuanjia@jd.com>
Date: Sat, 8 May 2021 09:47:13 +0800
Subject: [PATCH] check resuming len to avoid panic

---
 client/v3/watch.go | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/client/v3/watch.go b/client/v3/watch.go
index 73b65539e..b73925ba1 100644
--- a/client/v3/watch.go
+++ b/client/v3/watch.go
@@ -581,10 +581,12 @@ func (w *watchGrpcStream) run() {
 			switch {
 			case pbresp.Created:
 				// response to head of queue creation
-				if ws := w.resuming[0]; ws != nil {
-					w.addSubstream(pbresp, ws)
-					w.dispatchEvent(pbresp)
-					w.resuming[0] = nil
+				if len(w.resuming) != 0 {
+					if ws := w.resuming[0]; ws != nil {
+						w.addSubstream(pbresp, ws)
+						w.dispatchEvent(pbresp)
+						w.resuming[0] = nil
+					}
 				}
 
 				if ws := w.nextResume(); ws != nil {