
    Ii
                        S r SSKJr  SSKrSSKrSSKJrJrJrJ	r	  SSK
Jr  SSKJr  Sr\" S\S	\4   S
9rSS jr\R"                  S:  a  \R$                  r\R&                  rgSS jrSS jrg)z2Miscellaneous pieces that need to be synchronized.    )annotationsN)AnyCallableTypeVarcast)OperationFailure)_REAUTHENTICATION_REQUIRED_CODEFF.)boundc                4   ^  SU 4S jjn[        [        U5      $ )Nc                   >#    UR                  SS5      nSSKJn  SSKJn   T" U 0 UD6I S h  vN $  N! [
         a  nU(       a  e UR                  [        :X  ak  S nU  H5  n[        Xs5      (       a  Un  O"[        Xt5      (       d  M)  UR                  n  O   U(       a  UR                  SS9I S h  vN    Oe T" U 0 UD6s S nA$ e S nAff = f7f)N	no_reauthFr   )AsyncConnection)_BulkWriteContextT)reauthenticate)poppymongo.asynchronous.poolr   pymongo.messager   r   coder	   
isinstanceconnauthenticate)	argskwargsr   r   r   excr   argfuncs	           B/venv/lib/python3.13/site-packages/pymongo/asynchronous/helpers.pyinner_handle_reauth.<locals>.inner'   s     JJ{E2	=5	t.v.... 	xx:: C!#77"!#99"xx   ++4+@@@T,V,,)	sU   C5 35 C5 
CAC)C1B42C CCCCC)r   r   r   r   returnr   )r   r
   )r   r   s   ` r   _handle_reauthr"   &   s    : 5>    )   
   c                >   #    U R                  5       I Sh  vN $  N7f)iCompatibility function until we drop 3.9 support: https://docs.python.org/3/library/functions.html#anext.N)	__anext__clss    r   anextr+   L   s     ]]_$$$s   c                "    U R                  5       $ )r'   )	__aiter__r)   s    r   aiterr.   P   s    }}r#   )r   r
   r!   r
   )r*   r   r!   r   )__doc__
__future__r   builtinssystypingr   r   r   r   pymongo.errorsr   pymongo.helpers_sharedr	   _IS_SYNCr
   r"   version_infor+   r.    r#   r   <module>r9      sv    9 "  
  C CxS)*B wNNENNE%r#   