zTddlZddlmZmZmZmZedZdZGddeeZy)N)GenericTypeVarCallableOptional_ClientKcveZdZUegefZeed<eeed<eed<e jed<defdZ defdZ y ) ClientCache_factory_latest_remaining_uses_lockfactoryc`||_d|_d|_tj|_y)Nr)r r r threadingLockr)selfrs Elib/third_party/google/cloud/pubsublite/internal/wire/client_cache.py__init__zClientCache.__init__s&   ^^% returnc|j5|jdkr t|_|j|_|xjdzc_|jcdddS#1swYyxYw)Nr)rr _MAX_CLIENT_USESr r )rs rgetzClientCache.get$sN ZZ##q('7$#}}  A % << ZZs AA''A0N) __name__ __module__ __qualname__rr_ClientFactory__annotations__rintrrrrrrr r sIb'k*N g  >>&&  W rr ) rtypingrrrrrrr r"rrr$s177 )  ''" r