MCPcopy
hub / github.com/grpc/grpc-go / newTestWatcher

Function newTestWatcher

internal/xds/xdsdepmgr/xds_dependency_manager_test.go:85–91  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

83}
84
85func newTestWatcher() *testWatcher {
86 return &testWatcher{
87 updateCh: make(chan *xdsresource.XDSConfig, 1),
88 errorCh: make(chan error),
89 done: make(chan struct{}),
90 }
91}
92
93// Update sends the received XDSConfig update to the update channel. Does not
94// send updates if the done channel is closed. The done channel is closed in the

Calls

no outgoing calls

Tested by

no test coverage detected