.

go/neo/client.go

@@ -331,6 +331,9 @@ func (c *Client) recvMaster1(ctx context.Context, req neonet.Request) error {
 		c.node.UpdateClusterState(ctx, msg)
 	}
 
+	// XXX
+	// *proto.InvalidateObjects -> watchq
+
 	// update .operational + notify those who was waiting for it
 	opready := c.updateOperational()
 	c.node.StateMu.Unlock()

go/neo/client_test.go

@@ -268,7 +268,6 @@ func TestLoad(t *testing.T) {
 }
 
 func TestWatch(t *testing.T) {
-	t.Skip("FIXME currently hangs")
 	withNEOSrv(t, func(t *testing.T, nsrv NEOSrv) {
 		xtesting.DrvTestWatch(t, fmt.Sprintf("neo://%s@%s", nsrv.ClusterName(), nsrv.MasterAddr()), openClientByURL)
 	})