(*, force_refresh: bool = False)
| 1551 | release_refresh = _threading.Event() |
| 1552 | |
| 1553 | def provider(*, force_refresh: bool = False) -> AccessToken: # noqa: ARG001 |
| 1554 | provider_calls.append(1) |
| 1555 | refresh_started.set() |
| 1556 | release_refresh.wait(timeout=2) |
| 1557 | return tokens[len(provider_calls) - 1] |
| 1558 | |
| 1559 | cache = TokenCache(provider, time_source=clock) |
| 1560 | # Prime the cache with token 'a'. |
no test coverage detected