e/SSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSKJ r SSK J r J r SSK Jr SSKJrJr SSKJr SS KJr SS KJr SS KJr SS KJrJrJr S r\Rr"SS\5r "SS\!5r"g))unicode_literalsN) InputStream) DummyContextin_main_thread)Input) EventLoop INPUT_TIMEOUT)EventLoopCallbacks)InputHookContext)PosixStdinReader)TimeIt) AutoSelectorSelector fd_to_int)PosixEventLoopcd\rSrSrSrS\4SjrSrSSjrSr Sr SS jr S r S r S rS rSrg)rz1 Event loop for posix systems (Linux, Mac os X). NcUb[U5(de[U[5(deSUlSUlSUlSUl/Ul0UlU"5Ul [R"5Ul [R"URS[R[R5 U(a[!U5UlgSUlg)NFr)callable issubclassrrunningclosed_running _callbacks_calls_from_executor _read_fdsselectorospipe_schedule_pipefcntlF_SETFL O_NONBLOCKr _inputhook_context)self inputhookrs 1lib/third_party/prompt_toolkit/eventloop/posix.py__init__PosixEventLoop.__init__s HY$7$777(H----   $&!  !ggi D''*EMM2==IBK"29"=PTcL^^^^[U[5(de[U[5(deTR(aeTR(a [ S5eSTlUTl[UR5m[/m[UR55m[5(a[TR5nO [5nUUUU4SjnTR!X5 TR!TR"SS5 U TR(Ga"TR$(aB['5nUU4SjnTR$R)U5 SSS5 WR*nOSnTScSnO[-STSU- 5nTR/U5n U (Ga`/n /n Sn U Hn U TR"S:XaTR0HXupUcU R3U5 MU =(d [55n X:aU R3U5 MFU R3X45 MZ /Tl[6R8"TR"SS5 MTR:R=U 5nU(dMU R3U5 M [>R@"U 5 [>R@"U 5 U (a-U H nU"5 M U HunnTRCUUS9 M O9U H unnU"5 M O%TRE5 URG5 STS'TR(aGM"SSS5 TRIU5 TRITR"S5 STlg!,(df  GN*=f!,(df  NW=f) z The input 'event loop'. zEvent loop already closed.Tc>TR5nTRU5 [TS'TR(aTR 5 gg)zRead user input. rN)readfeedr rstop)datacurrent_timeout inputstreamr& stdin_readers r(read_from_stdin+PosixEventLoop.run..read_from_stdinOsF $$&D   T ""/OA "" #r+rNcR>TRU(a TS5/:g$S5/:g$)zETrue when there is input ready. The inputhook should return control. r)_ready_for_reading)waitr2r&s r(ready!PosixEventLoop.run..readyds1#'#:#:QU?1;M#]ac#cc[\#]ac#ccr+i)_max_postpone_until)% isinstancerr rr Exceptionrrfeed_keyr r filenorcall_on_sigwinchreceived_winchr add_readerr!r%rcall_inputhookdurationmaxr8rappend_nowrr.rgetrandomshufflecall_from_executorflush input_timeout remove_reader)r&stdin callbacksctxr5inputhook_timerr:inputhook_durationremaining_timeoutfdstaskslow_priority_tasksnowfdcmax_postpone_untilhandlert_r2r3r4s` @@@r(runPosixEventLoop.run2s%'''')%78888==  ;;89 9 #!)"4"45 (/( 7   "4#6#67C.C   / ++A.5 ---**_d//>>uE " *9)A)A&)*&#1%-(,%(+Aq/ADV/V(W%--.?@E)+&C!!4!4Q!779=9R9R 5#5#=$)LLO+.-C'9'?(- Q(:(A(A1BY(Z:S9;D5GGD$7$7$:DA&*nn&8&8&TR(aTRR5 ggN)rterminal_size_changedr&sr( process_winch4PosixEventLoop.received_winch..process_winchs557r+NrL)r&rks` r(rBPosixEventLoop.received_winchs 8  .r+c4^U4SjnURU5 g)z Run a long running function in a background thread. (This is recommended for code that could block the event loop.) Similar to Twisted's ``deferToThread``. cJ>[R"TS9R5 g)N)target) threadingThreadstartcallbacksr(start_executor6PosixEventLoop.run_in_executor..start_executors   H - 3 3 5r+Nrm)r&rvrws ` r(run_in_executorPosixEventLoop.run_in_executors 6 /r+cUb[U[5(deURRX45 UR(a&[ R "URSS5 gg![[[4a gf=f)aP Call this function in the main event loop. Similar to Twisted's ``callFromThread``. :param _max_postpone_until: `None` or `time.time` value. For interal use. If the eventloop is saturated, consider this task to be low priority and postpone maximum until this timestamp. (For instance, repaint is done using low priority.) Nrx) r=floatrrGr!rwriteAttributeError IndexErrorOSError)r&rvr<s r(rL!PosixEventLoop.call_from_executors}#*j9Le.T.TTT !!((()HI    ,,Q/6 #J8    s $A//BBcSUlg)z Stop the event loop. FN)rrjs r(r0PosixEventLoop.stops  r+cSUlURnSUlU(a2[R"US5 [R"US5 UR(aURR5 gg)NTrr)rr!rcloser%)r& schedule_pipes r(rPosixEventLoop.closesc ++ "  HH]1% & HH]1% &  " "  # # ) ) + #r+cl[U5nX RU'URRU5 g)z,Add read file descriptor to the event loop. N)rrrregister)r&rZrvs r(rCPosixEventLoop.add_readers) r]%r r"r+c[U5nXR;a URU URRU5 g)z1Remove read file descriptor from the event loop. N)rrr unregister)r&rZs r(rOPosixEventLoop.remove_readers3 r]  r"   $r+) rrr%rrr!rrrrh)__name__ __module__ __qualname____firstlineno____doc__rr)r`r8rBryrLr0rrCrO__static_attributes__r+r(rrsC"& U(IV/$0&. ,# %r+rc*\rSrSrSrSrSrSrSrg)rAi$zj Context manager which Installs a SIGWINCH callback. (This signal occurs when the terminal size changes.) cXlSUlgrhrvprevious_callback)r&rvs r(r)call_on_sigwinch.__init__)s !%r+cb^[R"[RU4Sj5Tlg)Nc$>TR5$rhru)ar&s r(,call_on_sigwinch.__enter__...s 4==?r+)signalSIGWINCHrrjs`r( __enter__call_on_sigwinch.__enter__-s!'v@Z![r+cURc&[R"[RS5 g[R"[RUR5 g)Nr)rrr)r&rkws r(__exit__call_on_sigwinch.__exit__0s:  ! ! ) MM&//1 - MM&//4+A+A Br+rN) rrrrrr)rrrrr+r(rArA$s&\Cr+rA)# __future__rr"rrJrrrtime#prompt_toolkit.terminal.vt100_inputrprompt_toolkit.utilsrrprompt_toolkit.inputrbaser r rQr r'r posix_utilsr utilsrrcrrr__all__rHrobjectrArr+r(rsg'  ;=&*)')55  yyG%YG%TCvCr+