+ 8Li*Rt^RIt^RIt^RIt^RIHt^RIHt^RIH t H t H t H t H t HtHtHtHtHtHt^RIt^RIHt^RIHt^RIHt]P6R8d^RIHtM^RIHt]P<!]4t ] PB] PD] PF] PH3wt!t"t#t%!R R ]4t&!R R ]4t']]&]'3,t(!R R4t)!RR]*4t+R#)z&Synchronous msgpack-rpc session layer.N)deque) format_exc) AnyAnyStrCallableDequeList NamedTupleOptionalSequenceTupleUnioncast) check_async AsyncSession BaseEventLoop)Literalc0a]tRt^toRtV3RltRtVtR#)RequestzA request from Nvim.ch<V^8dQh/S[R,;R&S[;R&S[S[,;R&S[;R&#)requesttypenameargsresponserstrrr)format __classdict__s""Session.__init__..As i!or%) _async_session _request_cb_notification_cbr_pending_messages _is_running_setup_exception _loop_thread error_wrapper)selfr9s&&r"__init__Session.__init__7sE+GKLP16 598< % r%c <V^8dQhRS[/#rreturnr)r r!s"r"r#r:Ds((m(r%c .VPP#)z%Get the underlying msgpack EventLoop.)rClooprKs&r"rR Session.loopCs""'''r%cD<V^8dQhRS[RS[3,RS[RS[RR/#)rfn.rkwargsrPN)rr)r r!s"r"r#r:Hs6>>38$>-0> >r%c `aaaaVVV3RloV3RlpVPPV4R#)z.Wrapper around `AsyncSession.threadsafe_call`.c><S!S/SBR# \dR#i;iNr>)rrVrWsr"handler(Session.threadsafe_call..handlerLs' D#F#  s  cT<\P!S4pVP4R#rZgreenletswitch)grr[s r"greenlet_wrapper1Session.threadsafe_call..greenlet_wrapperTs""7+B IIKr%N)rCthreadsafe_call)rKrVrrWrbr[s&fjl @r"rdSession.threadsafe_callHs$   ++,<=r%c0<V^8dQhRS[S[,/#rO)r Message)r r!s"r"r#r:Zshw/r%c PVP'd \R4hVP'dVPP4#VPP VP VP4VP'dVPP4#R#)zBlock until a message(request or notification) is available. If any messages were previously enqueued, return the first in queue. If not, run the event loop until one is received. zEvent loop already runningN)rGr?rFpopleftrCrun_enqueue_request_and_stop_enqueue_notification_and_stoprSs&r" next_messageSession.next_messageZs    89 9  ! ! !))113 3  > > $ C C E  ! ! !))113 3r%c2<V^8dQhRS[RS[RS[RS[/#)rmethodrrWrP)rr)r r!s"r"r#r:js)''f'S'C'C'r%c \VPRR4VR4pV'dVPPW4R#V'd8\ RP RP VP4444hVP'dVPW4pMVPW4pV'g \R4hVwrgV'dVPV4hV#)aSend a msgpack-rpc request and block until as response is received. If the event loop is running, this method must have been called by a request or notification handler running on a greenlet. In that case, send the quest and yield to the parent greenlet until a response is available. When the event loop is not running, it will perform a blocking request like this: - Send the request - Run the loop until the response is available - Put requests/notifications received while waiting into a queue If the `async_` flag is present and True, a asynchronous notification is sent instead. This will never block, and the return value or error is ignored. async_NFz/request got unsupported keyword argument(s): {}z, EOF) rpoprCnotify ValueErrorr joinkeysrG_yielding_request_blocking_requestOSErrorrJ)rKrprrWrrverrrvs&&*, r"rSession.requestjs$VZZ$7G     & &v 4  N$fTYYv{{}%=>@ @    &&v4A&&v4A%.   $$S) ) r%Nc <V^8dQhRS[S[S[S[,.R3,RS[S[S[S[,.R3,RS[S[.R3,,RR/#)r request_cbNnotification_cbsetup_cbrP)rrrrr )r r!s"r"r#r:sf-(-( #tCy!14!78-(%sDI&6&<=-(xD12-(?C-(r%c aaVSnVSnRSnRSn\P !4SnRVV3RllpS'd'\P!V4pVP4SP'dSPhSP'dJSPP4p\SRPV^,44!VR,!K[SPPSPSP 4RSnRSnRSnRSnSP'd SPhR#)zRun the event loop to receive requests and notifications from Nvim. Like `AsyncSession.run()`, but `request_cb` and `notification_cb` are inside greenlets. TNcV^8dQhRR/#rrPNr&)r s"r"r#!Session.run..__annotate__s  $ r%cx<S!4R# \d#pTSnSP4Rp?R#Rp?ii;irZ)r?rHstop)r@rKrs r"on_setupSession.run..on_setups0   ()%  s 949z_on_{}:r=NNF)rDrErGrH threadingcurrent_threadrIr_r`rFrigetattrr rCrj _on_request_on_notification)rKrrrrramsgsf&&f r"rj Session.runs& / $%446   ""8,B IIK  '' '$$$((002C D(//#a&1 2CG <  0 0$2G2GH  $   '' ' !r%c<V^8dQhRR/#rr&)r r!s"r"r#r:s##d#r%c :VPP4R#)zStop the event loop.N)rCrrSs&r"r Session.stops   "r%c<V^8dQhRR/#rr&)r r!s"r"r#r:s$$t$r%c :VPP4R#)zClose the event loop.N)rCcloserSs&r"r Session.closes !!#r%c h<V^8dQhRS[RS[S[,RS[S[S[S[3,S[3,/#rrprrPrr rr intr)r r!s"r"r#r:s;$,SM uS#X# $r%ca\P!4oSPpV3RlpVPP WV4VP 4#)c,<SPW4R#rZ)r`)r}r~ras&&r" response_cb.Session._yielding_request..response_cbs  IIc r%)r_ getcurrentparentrCrr`)rKrprrrras&&& @r"rySession._yielding_requestsH "  ##F+> }}r%c h<V^8dQhRS[RS[S[,RS[S[S[S[3,S[3,/#rr)r r!s"r"r#r:s@ @ @  @(0  @ uS#X# $ @r%c&aa.oVV3RlpSPPWV4SPPSPSP4\ \ \ \\3,\3,\S44#)cL<SPW.4SP4R#rZ)extendr)r}r~resultrKs&&r"r.Session._blocking_request..response_cbs MM3) $ IIKr%) rCrrj_enqueue_request_enqueue_notificationrr rrrtuple)rKrprrrsf&& @r"rzSession._blocking_requestso  ##F+>  5 5 $ : : <E%S/3./v??r%c@<V^8dQhRS[RS[S[,RS[RR/#rrrrrPNrrr)r r!s"r"r#r:s1#Cy47 r%cJVPWV4VP4R#rZ)rrrKrrrs&&&&r"rk!Session._enqueue_request_and_stops d(3 r%c:<V^8dQhRS[RS[S[,RR/#rrrrPNr)r r!s"r"r#r:s&3d3iDr%cHVPW4VP4R#rZ)rrrKrrs&&&r"rl&Session._enqueue_notification_and_stops ""4. r%c@<V^8dQhRS[RS[S[,RS[RR/#rr)r r!s"r"r#r:s3QQSQS QSQTQr%cRVPP\RWV44R#)rN)rFappendrrs&&&&r"rSession._enqueue_requests %%giX&OPr%c:<V^8dQhRS[RS[S[,RR/#rr)r r!s"r"r#r:s+QQ#QT#YQ4Qr%cPVPP\RW44R#)r4N)rFrr2rs&&&r"rSession._enqueue_notifications %%l>4&OPr%cnaaaaVVVV3Rlp\P!V4pVP4R#)c^<SPSS4pSPV4R# \d1pSPTP^,RR7Rp?R#Rp?i\d@pSP\ T4R,\ ^4,RR7Rp?R#Rp?ii;i)T)errorN )rDsend ErrorResponserr?reprr)r~r}rrrrKs r"r[$Session._on_request..handlers L%%dD1 b! ! 7 chhqk 66   L d3i$.A>d KK   Ls&$) B,%A B,,B,-4B''B,Nr^)rKrrrr[rasffff r"rSession._on_requests+  *  w '  r%cjaaaVVV3Rlp\P!V4pVP4R#)cT<SPSS4R# \dR#i;irZ)rEr?)rrrKsr"r[)Session._on_notification..handlers9 %%dD1      s  ''Nr^)rKrrr[rasfff r"rSession._on_notifications&   w '  r%)rCrGrIrErFrDrHrJrZ)r(r)r*r+r,rLpropertyrRrdrmrrjrrryrzrkrlrrrrr.r/r0s@r"r7r7.s & &((>>$ ''R-(-(^##$$ @ @ QQQQ6r%r7c]tRtRtRtRtR#)ri'aRaise this in a request handler to respond with a given error message. Unlike when other exceptions are caught, this gives full control off the error response sent. When "ErrorResponse(msg)" is caught "msg" will be sent verbatim as the error response.No traceback will be appended. r&N)r(r)r*r+r,r.r&r%r"rr's  r%r)),r,loggingsysr collectionsr tracebackrtypingrrrrrr r r r r rr_ pynvim.compatr pynvim.msgpack_rpc.async_sessionr"pynvim.msgpack_rpc.event_loop.baser version_infotyping_extensionsr getLoggerr(loggerrdebuginfowarningwarnrr2rgr7 BaseExceptionrr&r%r"rs,  ((((%9<f)   8 $"LL&,, "NN-udDj: % &vvr  M  r%