diff --git a/proxy/grpcproxy/watcher_groups.go b/proxy/grpcproxy/watcher_groups.go index 514b5b44d..eef879d57 100644 --- a/proxy/grpcproxy/watcher_groups.go +++ b/proxy/grpcproxy/watcher_groups.go @@ -72,10 +72,10 @@ func (wgs *watchergroups) maybeJoinWatcherSingle(rid receiverID, ws watcherSingl wgs.mu.Lock() defer wgs.mu.Unlock() - gropu, ok := wgs.groups[ws.w.wr] + group, ok := wgs.groups[ws.w.wr] if ok { - if ws.w.rev >= gropu.rev { - gropu.add(receiverID{streamID: ws.sws.id, watcherID: ws.w.id}, ws.w) + if ws.w.rev >= group.rev { + group.add(receiverID{streamID: ws.sws.id, watcherID: ws.w.id}, ws.w) return true } return false