diff --git a/proxy/grpcproxy/watch.go b/proxy/grpcproxy/watch.go
index eae98e3b2..179859a84 100644
--- a/proxy/grpcproxy/watch.go
+++ b/proxy/grpcproxy/watch.go
@@ -254,6 +254,7 @@ func (wps *watchProxyStream) recvLoop() error {
 			}
 			if !w.wr.valid() {
 				w.post(&pb.WatchResponse{WatchId: -1, Created: true, Canceled: true})
+				wps.mu.Unlock()
 				continue
 			}
 			wps.nextWatcherID++