+
    Bi                         R t ^ RIt^ RIt^ RIHt ^ RIHt R t ! R R]P                  4      t]	R8X  d   ]P                  ! 4        R# R# )zTests for asyncio/threads.pyN)
ContextVar)mockc                  D    \         P                  P                  R 4       R # N)asyncioevents_set_event_loop_policy     5/usr/lib/python3.14/test/test_asyncio/test_threads.pytearDownModuler   
   s    NN))$/r
   c                   D   a  ] tR t^t o R tR tR tR tR tR t	Rt
V tR# )	ToThreadTestsc                   "   \         P                  ! \        ^(^.4      G Rj  xL
 pV P                  V^*4       R#  L5i)(   N)r   	to_threadsumassertEqual)selfresults   & r   test_to_threadToThreadTests.test_to_thread   s3     ((r1g66$ 7s   !><>c                   "   R  pV P                  \        R4      ;_uu_ 4        \        P                  ! V4      G Rj  xL
  RRR4       R#  L  + '       g   i     R# ; i5i)c                      \        R 4      h)test)RuntimeErrorr	   r
   r   raise_runtime=ToThreadTests.test_to_thread_exception.<locals>.raise_runtime   s    v&&r
   r   N)assertRaisesRegexr   r   r   )r   r   s   & r   test_to_thread_exception&ToThreadTests.test_to_thread_exception   sI     	' ##L&99##M222 :92 :99s,   "A#AAA
A#AA 		A#c                   "   \         P                  ! 4       p\        P                  ! V4      G R j  xL
  VP	                  4        R #  L5ir   )r   Mockr   r   assert_called_oncer   funcs   & r   test_to_thread_once!ToThreadTests.test_to_thread_once   s5     yy{%%%! 	&s   /A
AA
c                  a"   . oV3R  lp. p\        ^
4       F*  p\        P                  ! V4      pVP                  V4       K,  	  \        P                  ! V!  G Rj  xL
  V P                  \        S4      ^
4       R#  L!5i)c                  *   < S P                  ^4       R# )   N)append)callss   r   r%   5ToThreadTests.test_to_thread_concurrent.<locals>.func"   s    LLOr
   N)ranger   r   r+   gatherr   r   )r   r%   futs_futr,   s   &    @r   test_to_thread_concurrent'ToThreadTests.test_to_thread_concurrent    sn     	 rA##D)CKK  nnd###UR( 	$s   ABB "Bc                   "   \         P                  ! 4       p\        P                  ! VR RR7      G Rj  xL
  VP	                  R RR7       R#  L5i)r   T)	somethingN)r   r"   r   r   assert_called_once_withr$   s   & r   test_to_thread_args_kwargs(ToThreadTests.test_to_thread_args_kwargs-   s@     yy{f===$$Vt$< 	>s   2AAAc                   a"   \        R 4      oV3R lpSP                  R4       \        P                  ! V4      G Rj  xL
 pV P	                  VR4       R#  L5i)test_ctxc                  $   < S P                  4       # r   )get)r;   s   r   get_ctx9ToThreadTests.test_to_thread_contextvars.<locals>.get_ctx8   s    <<>!r
   parrotN)r   setr   r   r   )r   r>   r   r;   s   &  @r   test_to_thread_contextvars(ToThreadTests.test_to_thread_contextvars5   sK     j)	" 	X((11* 2s   <AA Ar	   N)__name__
__module____qualname____firstlineno__r   r   r&   r3   r8   rB   __static_attributes____classdictcell__)__classdict__s   @r   r   r      s(     %3")=	+ 	+r
   r   __main__)__doc__r   unittestcontextvarsr   r   r   IsolatedAsyncioTestCaser   rD   mainr	   r
   r   <module>rQ      sD    "   " 00+H44 0+f zMMO r
   