compile error

2016-12-16 00:43:45 -08:00
parent 215f4fc30f
commit de30886c9e
1 changed files with 1 additions and 1 deletions
@@ -205,7 +205,7 @@ func (ws *watchSubscription) eventDispatchLoop(poster *Poster) {
 		// sends a different type when ev.Type == ERROR?)
 		poster.Post(string(ev.Type), ws.Watch.ObjType, ws.Watch.Url, &buf)
 	}
-	if !atomic.LoadInt32(ws.stopped) {
+	if atomic.LoadInt32(ws.stopped) != 0 {
 		// TODO re-watch.  What about resource version?
 		log.Panicf("Watch channel closed unexpectedly")
 	}