!h9zSSKJr SSKrSSKrSSKJr SSKJrJrJ r J r SSK J r J r SSKJrJr SSKJr SSKJr \(a.SS KJrJr SS KJr SS KJr SS KJr SS KJr SSKJ r \ "S5r!\ "S5r"SSjr#"SS\ \"5r$SSjr%SSjr&S S!Sjjr'S"Sjr(S#Sjr)S$Sjr*S%Sjr+S&Sjr,S&Sjr-g)') annotationsN)suppress) TYPE_CHECKINGAnyGenericTypeVar)catch_warningsfilterwarnings)asyncioreactorerror)Deferred) load_object)AbstractEventLoopAbstractEventLoopPolicy)Callable) DelayedCall) ServerFactory)Port) ParamSpec_P_Tc^SSKJn [U5S:a[SU35eU(dUR SX!S9$[U5S:XaUR USX!S9$[ USUSS-5HnUR XBUS9s $ g![ Ra X@S:XaeM9f=f)zfloatreturnNonerQrR)rQr) __name__ __module__ __qualname____firstlineno____doc__r8r?rBrHrN__static_attributes__r:r(r+r+0s -8   *r:r+c[5 g)zThe policy functions from asyncio often behave unexpectedly, so we restrict their use to the absolutely essential case. This should only be used to install the reactor. N)_get_asyncio_event_loop_policyrZr:r(set_asyncio_event_loop_policyr]Zs #$r:c[R"5n[RS:XaJ[ U[R 5(d+[R "5n[R "U5 U$)Nwin32)asyncioget_event_loop_policysysplatform isinstanceWindowsSelectorEventLoopPolicyset_event_loop_policy)policys r(r\r\bsV  * * ,F ||wz66((779%%f- Mr:c[U5nU[RLaL[5 [ [ R 5 [U5n[R"US9 SSS5 gURS5GtpE/UQSPn[SRU55n[ [ R 5 U"5 SSS5 g!,(df  g=f!,(df  g=f)zInstalls the :mod:`~twisted.internet.reactor` with the specified import path. Also installs the asyncio event loop with the specified import path if the asyncio reactor is enabled) eventloopN.install) rr AsyncioSelectorReactorr]rr ReactorAlreadyInstalledErrorset_asyncio_event_looprksplitjoin) reactor_pathevent_loop_path reactor_class event_loopmodule_installer_path installers r(install_reactorryls -M===%' e88 9/@J  " "Z 8: 9"'', -6-9- 89 e88 9 K: 9: 9: 9s C7C C C'c[S5$r.)rnrZr:r(_get_asyncio_event_loopr{~s !$ ''r:cUbD[U5n[5n[X!5(dU"5n[R"U5 U$[ 5 [ SS[S9 [R"5nSSS5 U$!,(df  W$=f![a/ [R"5n[R"U5 U$f=f)z;Sets and returns the event loop with specified import path.NignorezThere is no current event loop)messagecategory) rr{rdr`set_event_loopr r DeprecationWarningget_event_loop RuntimeErrornew_event_loop)rrevent_loop_classrts r(rnrns"4?4P,. *77)+J  " ": .. + /!</ %335 "( )"!(  / !//1J  " ": .  /s0 B%B8B B BB5C  C c SSKJn [U5nURU:Xd3[ SUR SURR SUS35eg)zsRaises :exc:`Exception` if the installed :mod:`~twisted.internet.reactor` does not match the specified import path.rrzThe installed reactor (rjz$) does not match the requested one ()N)rrr __class__rrUrT)rqrrss r(verify_installed_reactorrsg) -M    - ""#1W%6%6%?%?$@A((4~Q 8   .r:c<SSKJn [U5n[URU5(agURR R SURR R3nUR SUR3n[SUSUS35e)NrrrjzUScrapy found an asyncio Twisted reactor already installed, and its event loop class (zF) does not match the one specified in the ASYNCIO_EVENT_LOOP setting (r) rrrrd_asyncioEventlooprrUrVr) loop_pathr loop_class installed specifieds r(#verify_installed_asyncio_event_looprs(Y'J'++Z88  $ $ . . 9 9 : G % % / / < < = ?(():+B+B*CDI  009{;;a ! r:c(S[R;$)Nztwisted.internet.reactor)rbmodulesrZr:r(is_reactor_installedrs % 44r:cv[5(d [S5eSSKJn [ U[ R 5$)a|Check whether the installed reactor is :class:`~twisted.internet.asyncioreactor.AsyncioSelectorReactor`. Raise a :exc:`RuntimeError` if no reactor is installed. .. versionchanged:: 2.13 In earlier Scrapy versions this function silently installed the default reactor if there was no reactor installed. Now it raises an exception to prevent silent problems in this case. zCis_asyncio_reactor_installed() called without an installed reactor.rr)rrrrrdr rlrs r(is_asyncio_reactor_installedrs5 ! ! Q  ) g~DD EEr:)r$z list[int]r%strr&rrQrrS)rQrr.)rqrrr str | NonerQrR)rQr)rrrrQr)rqrrQrR)rrrQrR)rQbool). __future__rr`rb contextlibrtypingrrrrwarningsr r rr r twisted.internet.deferr scrapy.utils.miscrrrcollections.abcrtwisted.internet.basertwisted.internet.protocolrtwisted.internet.tcprtyping_extensionsrrrr)r+r]r\ryr{rnrrrrrZr:r(rs" 7732+)B(17), 4B T]$'*GBK'*T%$(B  &5Fr: