
    z                     T    S SK r S SKJrJrJrJr  \" S5      rSr " S S\\   5      rg)    N)GenericTypeVarCallableOptional_ClientK   c                       \ rS rSr% \/ \4   r\\S'   \\   \S'   \	\S'   \
R                  \S'   S\4S jrS\4S	 jrS
rg)ClientCache   _factory_latest_remaining_uses_lockfactoryc                 `    Xl         S U l        SU l        [        R                  " 5       U l        g )Nr   )r   r   r   	threadingLockr   )selfr   s     Elib/third_party/google/cloud/pubsublite/internal/wire/client_cache.py__init__ClientCache.__init__   s$     ^^%
    returnc                     U R                      U R                  S::  a   [        U l        U R                  5       U l        U =R                  S-  sl        U R                  sS S S 5        $ ! , (       d  f       g = f)Nr      )r   r   _MAX_CLIENT_USESr   r   )r   s    r   getClientCache.get$   sN    ZZ##q('7$#}}  A% << ZZs   AA((
A6)r   r   r   r   N)__name__
__module____qualname____firstlineno__r   r   _ClientFactory__annotations__r   intr   r   r   r   __static_attributes__ r   r   r
   r
      sI    b'k*Ng>>& & W  r   r
   )	r   typingr   r   r   r   r   r   r
   r'   r   r   <module>r)      s1     7 7
)
  ''"  r   