proxy/grpcproxy: broadcast original watch ID

Signed-off-by: Gyuho Lee <gyuhox@gmail.com>
etcd-io · Jun 14, 2018 · 50858d3 · 50858d3
1 parent e96a53c
commit 50858d3
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/proxy/grpcproxy/watcher.go b/proxy/grpcproxy/watcher.go
@@ -112,8 +112,10 @@ func (w *watcher) send(wr clientv3.WatchResponse) {
 		Created:         wr.Created,
 		CompactRevision: wr.CompactRevision,
 		Canceled:        wr.Canceled,
-		WatchId:         w.id,
 		Events:          events,
+
+		// broadcast original watch ID to coalesced watch streams
+		WatchId: wr.ID,
 	})
 }