From ed2bd68d2852167737a3fdf51b15b13bfee807de Mon Sep 17 00:00:00 2001
From: Asim Aslam <asim@aslam.me>
Date: Sun, 19 Jan 2020 23:22:41 +0000
Subject: [PATCH] fix break in router service

---
 router/service/watcher.go | 2 ++
 1 file changed, 2 insertions(+)

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() {