ovok_sdk.auth.single_flight

Deduplication of concurrent calls, such as token refreshes.

SingleFlightCopy Anchor Link

SingleFlight()

Bases: Generic[T]

Runs one call at a time; callers who arrive while it runs share its outcome instead of repeating it.

run()Copy Anchor Link

run(call: Callable[[], T]) -> T

Run call, or wait for the run in progress and share its outcome.

Returns

• T: The call's result.

Raises

• Exception: Whatever the shared call raised.