fix break in router service

ylsGit · Jan 19, 2020 · ed2bd68 · ed2bd68
1 parent 97928e8
commit ed2bd68
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/router/service/watcher.go b/router/service/watcher.go
@@ -14,13 +14,15 @@ 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) {
 	w := &watcher{
 		opts:    opts,
 		resChan: make(chan *router.Event),
 		done:    make(chan struct{}),
+		stream:  rsp,
 	}
 
 	go func() {