(*, force_refresh: bool = False)
| 1645 | release_refresh = _threading.Event() |
| 1646 | |
| 1647 | def provider(*, force_refresh: bool = False) -> AccessToken: # noqa: ARG001 |
| 1648 | provider_calls.append(1) |
| 1649 | refresh_started.set() |
| 1650 | release_refresh.wait(timeout=2) |
| 1651 | return tokens[len(provider_calls) - 1] |
| 1652 | |
| 1653 | cache = TokenCache(provider, time_source=clock) |
| 1654 | # Prime the cache with token 'a'. |
no test coverage detected