diff --git a/xds/internal/resolver/xds_resolver_test.go b/xds/internal/resolver/xds_resolver_test.go index dc8eb181fa1a..95c26a6363e9 100644 --- a/xds/internal/resolver/xds_resolver_test.go +++ b/xds/internal/resolver/xds_resolver_test.go @@ -107,12 +107,12 @@ type testClientConn struct { } func (t *testClientConn) UpdateState(s resolver.State) error { - t.stateCh.Send(s) + t.stateCh.Replace(s) return nil } func (t *testClientConn) ReportError(err error) { - t.errorCh.Send(err) + t.errorCh.Replace(err) } func (t *testClientConn) ParseServiceConfig(jsonSC string) *serviceconfig.ParseResult {