We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 980c6ad commit e742220Copy full SHA for e742220
rtrefresh/rt_refresh_manager.go
@@ -104,7 +104,9 @@ func (r *RtRefreshManager) Close() error {
104
// error and close. The channel is buffered and safe to ignore.
105
func (r *RtRefreshManager) Refresh(force bool) <-chan error {
106
resp := make(chan error, 1)
107
+ r.refcount.Add(1)
108
go func() {
109
+ defer r.refcount.Done()
110
select {
111
case r.triggerRefresh <- &triggerRefreshReq{respCh: resp, forceCplRefresh: force}:
112
case <-r.ctx.Done():
0 commit comments