diff --git a/etcdserver/api/v3rpc/watch.go b/etcdserver/api/v3rpc/watch.go index 6e1164895..117b1f0fe 100644 --- a/etcdserver/api/v3rpc/watch.go +++ b/etcdserver/api/v3rpc/watch.go @@ -79,7 +79,6 @@ func sendLoop(stream pb.Watch_WatchServer, watcher storage.Watcher, closec chan } storage.ReportEventReceived() } - return } } }