(client ResumeTokenClient)
| 818 | } |
| 819 | |
| 820 | func (b *basicResumeTokenController) New(client ResumeTokenClient) CloserWaiter { |
| 821 | b.Lock() |
| 822 | defer b.Unlock() |
| 823 | if b.refresher != nil { |
| 824 | cErr := b.refresher.Close(context.Background()) |
| 825 | if cErr != nil { |
| 826 | b.logger.Debug(context.Background(), "closed previous refresher", slog.Error(cErr)) |
| 827 | } |
| 828 | } |
| 829 | b.refresher = newBasicResumeTokenRefresher(b.logger, b.clock, b, client) |
| 830 | return b.refresher |
| 831 | } |
| 832 | |
| 833 | func (b *basicResumeTokenController) Token() (string, bool) { |
| 834 | b.Lock() |
nothing calls this directly
no test coverage detected