o ]">> with timeout(0.001): ... async with aiohttp.get('https://github.com') as r: ... await r.text() timeout - value in seconds or None to disable timeout logic loop - asyncio compatible event loop NlooprreturncCs8||_|dur t}||_d|_d|_d|_d|_dS)NF)_timeoutasyncioget_event_loop_loop_task _cancelled_cancel_handler _cancel_at)selfrrrF/var/www/html/kck/venv/lib/python3.10/site-packages/asgiref/timeout.py__init__s ztimeout.__init__cCs|SN _do_enterrrrr __enter__-sztimeout.__enter__exc_typeexc_valexc_tbcCs||dSr_do_exitrrrrrrr__exit__0s ztimeout.__exit__cs |Srrrrrr __aenter__9sztimeout.__aenter__cs||dSrrr rrr __aexit__<sztimeout.__aexit__cCs|jSr)rrrrrexpiredDsztimeout.expiredcCs$|jdurt|j|jdSdS)Ng)rmaxr timerrrr remainingHs ztimeout.remainingcCsr|jdur|St|j|_|jdurtd|jdkr$|j|j|S|j|j|_|j |j|j|_ |S)Nz4Timeout context manager should be used inside a taskr) r current_taskr r RuntimeError call_soon _cancel_taskr&rcall_atrrrrrrOs    ztimeout._do_entercCsP|tjur|jrd|_d|_tj|jdur#|jdur#|jd|_d|_dSr)r CancelledErrorrrr TimeoutErrorr cancel)rrrrrrcs ztimeout._do_exitcCs"|jdur|jd|_dSdS)NT)rr/rrrrrr+ns   ztimeout._cancel_task)r r)r N)__name__ __module__ __qualname____doc__rfloatr AbstractEventLooprrr BaseExceptionrboolr!r"r#propertyr$r'rrr+rrrrrsJ     rrr zOptional[asyncio.Task[Any]]cCsLtjdkr tj|d}ntjj|d}|dur$t|dd}|dur$|}|S)N)rr()sys version_infor r(Taskgetattr)rtaskfnrrrr(ts  r() r r;typesrtypingrrrrr5r(rrrrs  e