etcdserver: watch stream got closed once one request is not permitted
@@ -255,10 +255,11 @@ func (sws *serverWatchStream) recvLoop() error {
select {
case sws.ctrlStream <- wr:
+ continue
case <-sws.closec:
- }
return nil
}
+ }
filters := FiltersFromRequest(creq)
