diff --git a/router/service/watcher.go b/router/service/watcher.go
index 2e1f52b4..38780f0e 100644
--- a/router/service/watcher.go
+++ b/router/service/watcher.go
@@ -14,6 +14,7 @@ type watcher struct {
 	opts    router.WatchOptions
 	resChan chan *router.Event
 	done    chan struct{}
+	stream  pb.Router_WatchService
 }
 
 func newWatcher(rsp pb.Router_WatchService, opts router.WatchOptions) (*watcher, error) {
@@ -21,6 +22,7 @@ func newWatcher(rsp pb.Router_WatchService, opts router.WatchOptions) (*watcher,
 		opts:    opts,
 		resChan: make(chan *router.Event),
 		done:    make(chan struct{}),
+		stream:  rsp,
 	}
 
 	go func() {