(o resolver.ResolveNowOptions)
| 97 | } |
| 98 | |
| 99 | func (ccr *ccResolverWrapper) resolveNow(o resolver.ResolveNowOptions) { |
| 100 | ccr.serializer.TrySchedule(func(ctx context.Context) { |
| 101 | if ctx.Err() != nil || ccr.resolver == nil { |
| 102 | return |
| 103 | } |
| 104 | ccr.resolver.ResolveNow(o) |
| 105 | }) |
| 106 | } |
| 107 | |
| 108 | // close initiates async shutdown of the wrapper. To determine the wrapper has |
| 109 | // finished shutting down, the channel should block on ccr.serializer.Done() |
nothing calls this directly
no test coverage detected