rust #rustc 1.98.1 (48a229cea 2026-09-01)RL.SAwjL-df1bddb45adbe94bm6GÂn62-64f5f36fb09276941 Xr*-1ad4f876c768bda9<%Z>64V`-2d2ab9fb0fe1def5G g{(3iF-06449a08aaab5e30rustc_std_workspace_core{`"Ei%G-cb0d4d77988d81b5")pE͗E-3ec41d3a5a80a4a4 miniz_oxide8bž LƨJ-e44eaef1807e5fc0adler29lyA6P/D$UB-dca52f01a59c33e7 hashbrownX {e-143c77bb957d9940rustc_std_workspace_alloc _z%-145a318e0772276c std_detectK(0*8D?-f99feda5ce9e492arustc_demangle%jerV-cfd0ab54bb33760ecfg_if}λ՞Co-360da4ba13154744 addr2linecY\G--09755979c57b7e64gimliQ`Dy-9a1fede77fbbf2f0objectF λv.z-7ff85ea729a864ffmemchr]1<=UO-0e3477fb2664a277 jlToKG-549498e8b2e4d924 futures_core.. Z-b2e86d4a91990c16 futures_taskŇO_SK-9dc53e607663f6e3 futures_util` oU1F-9051d6448dad3304 futures_macroi#ujМd{G`-fd2c0a1c627d5f7c futures_sink71G" &h-578a9e470927087cpin_project_lite/+,Dv9O-e9b26d79a08f0191futures_channelv|Lr-4c07352f2b9ac2b6slab;~bౄ9-a4a8269ffb724f29 futures_ioڵC{ҥ*ѳ-0d5040d36e03bfa0.o;_tbݤ-480240aaef38b342 thread_pool\ thread-pool unpark_mutexd  ThreadPoolT ThreadPoolBuilder ') local_pool      !Incoming ThreadNotify((unparked+ wake_by_ref run_executor--- woken1 3 3spawner3run6 3 run_until88 3 try_run_one; 3run_until_stalled= 3 poll_pool3drain_incomingA>block_onCC block_on_streamFHHHLLOO into_innerRRR R size_hintW spawn_objWstatusZspawn_local_objZ status_localentercccEnterf_privc EnterErrorhcjclcco cqcst    LocalPoolzpoolzincoming } LocalSpawner  CURRENT_THREAD_NOTIFY__rust_std_internal_init_fn  __RUST_STD_INTERNAL_VAL BlockingStreamstream cENTERED__RUST_STD_INTERNAL_INIT   ~8~8~88888,8-8-8586888;8=8?8?8?8@8888K8N8U8V8X8Y8[8\8k8k8k8m8m8m8r8r8r8t8gzz{|`\c5:Ƅ4gM(()*6PgЋz`%9U""Q  ghhic IggffgcP[.#}zjhqf+(AzHLRWZlhnhsfgWM""Q  g#(   3 ##FuturesUnordered#ready_to_run_queue"#head_all"# is_terminated"Y>LocalFutureObjfuture~drop_fn~_marker~#Mm  g   III -Iphantom-I-ZvH#000borrow.0.FrCCCbuf=C=FFFGlobal ě +"   -  gpv~ ÜĜŜƜǜȜ_w ĤĤŤError :M` k ggg cg cثq1ȡ      %% % "5 00Weak0 -0-n?QQ!"W\ &mu(   *5 ?& &Yc'(     &'3 [` gqvej #'$  '') (e  e KKKK 7K7K736"eřǙșəʙ˙G*R{9  řǙșəʙ˙G*R{9 * *B+&gainner;*ga^"++_| | a, )a (kD 87$e De*AAThreadA,=U/'o%``Va`68Rt'-Y.>./e e */6e  +,U .+ ee!e  11 #+ !eN $ee+ 11 11 T_eZeYe g*  9 e e3 Be e,e 2řǙșəʙ˙G*R{9  ,e ggStoragegfgf~[l(* 3__rust_std_internal_inituu3Y <, oM @l4 _U;d - , 077 *7U 7$ *0777777 ,<-7 7,4ÜĜŜƜǜȜ_w787_enter,6e648Q7W]7c*3,AP-B7l,t|, āL yl#4 "WakerRefwakerhhU)jrܰ # 7< T  7 #7 l< local_wakerext_marker28} t   7 "*l "'  / 5$ a f, A <  td 0))78[ *l<,>4 Waker<3e] <*ٴ۴ܴݴ޴ߴ}r7>> / GFݱ}L# 7 thread_notify{ 7<cx$<<=(>@@AY_ref__f4+Y, \ @4, :F l<==>8}ٴ۴ܴݴ޴ߴ}rFU Pin [$V=4F  ,d, -H:FGGIz6 ..+8+: HL+IL+F4+IT+FQFxI2I:IBJNRpinnedZFI@F F4,I|,4- \F/D-,$- FF-D-4--4-H- ٴH.$. I .L. ? 8.l.l. ٴHq{:,-C.? H, I3>,H4,IC0H%ٴ۴ܴݴ޴ߴ}r IIID4+I$+I  LbL=N _ref__future _ref__self WY,F4(W EFGGIW&dW -HEFGGRZ4 WWVuCWA:HLWF WI,WFQF@RI:>J@FoRFF WITW4WL)DWW$WL9WDWWEHW R>WIID WI,LLĚZ ZFYkY4Y -([ H[ '3 [`(lq`e[# $   YY (d\\K\=Yl\X,\ ,]]N]M ] L] 2\__Q^8 ^$^ ,`t` 4\``$` 04``.L` 8SSNextSҗg` ``_gUřǙșəʙ˙G*R{9 F`[L_Ix]G[e+\\r]L\aaLa H.\aaV`UřǙșəʙ˙G*R{9 ``X,`Y|`e  e 00a0.">eřǙșəʙ˙G*R{9  řǙșəʙ˙G*R{9 a aBb da,;adaYbb_\ L\ 0,f /+eaTG'_e e a/6e  1bcU .b eee  1f #b eN eeb 1f 1f T_cD C^| F_t`Lzadb, ow,fxThy)& Built-in executors and related tools.*.DA All asynchronous computation occurs within an executor, which issFC capable of spawning futures as tasks. This module provides several?< built-in executors, as well as tools for building your own.?< All items are only available when the `std` feature of this96 library is activated, and it is activated by default./, # Using a thread pool (M:N task scheduling)MJ Most of the time tasks should be executed on a [thread pool](ThreadPool).NK A small set of worker threads can handle a very large set of spawned tasksMJ (which are much lighter weight than threads). Tasks spawned onto the poolNK with the [`spawn_ok`](ThreadPool::spawn_ok) function will run ambiently on the created threads. # Spawning additional tasksKH Tasks can be spawned onto a spawner by calling its [`spawn_obj`] methodMJ directly. In the case of `!Send` futures, [`spawn_local_obj`] can be usedd instead. # Single-threaded executionKH In addition to thread pools, it's possible to run a task (and the tasksNK it spawns) entirely within a single thread via the [`LocalPool`] executor. NK Aside from cutting down on synchronization costs, this executor also makes GD it possible to spawn non-`Send` tasks, via [`spawn_local_obj`]. The OL [`LocalPool`] is best suited for running I/O-bound tasks that do relatively '$ little work between I/O operations.  JG There is also a convenience function [`block_on`] for simply running a /, future to completion on the current thread.  _\ [`spawn_obj`]: https://docs.rs/futures/0.3/futures/task/trait.Spawn.html#tymethod.spawn_obj pm [`spawn_local_obj`]: https://docs.rs/futures/0.3/futures/task/trait.LocalSpawn.html#tymethod.spawn_local_obj66|c   C^ F_ ` za b ow fx hy    t|T'(-1CFz, c owFuture4,Stream4NEll2<$'L \4ll D 000 .0.FrCCC =C=~~~#Mm " d 6P)*t 4 ((/D((/,O,$\ * B+ + ,arc_selfDHd77B././7 7 #7 l<==>8}"#7C< -773!|-0000-8,B 1|122221277U t4568;=?@&# Create a new, empty pool of tasks.B33\%52 Get a clonable handle to the pool as a [`Spawn`].< B3 3 5$$ ,) Run all tasks in the pool to completion.!%DA Runs all the tasks in the pool until the given future completes.&<&&%&&$& # let my_app = async {};''52 // run tasks in the pool until `my_app` completes' pool.run_until(my_app);<(((JG The function will block the calling thread *only* until the future `f`(JG completes; there may still be incomplete tasks in the pool, which will)KH be inert after the call completes, but can continue with further use of*IF one of the pool's run or poll methods. While the function is running,*=: however, all tasks in the pool will try to make progress.L+ FHB399 +3F +F4+ 8F# %(*$,8::::8I9%.TQ Runs all tasks and returns after completing one future or until no more progress/OL can be made. Returns `true` if one future was completed, `false` otherwise.0<00%0%" use futures::task::LocalSpawnExt;1*' use futures::future::{ready, pending};11$1! let spawner = pool.spawner();22,) spawner.spawn_local(ready(())).unwrap();2,2,) spawner.spawn_local(pending()).unwrap();3385 // Run the two ready tasks and return true for them.3QN pool.try_run_one(); // returns true after completing one of the ready futures4OL pool.try_run_one(); // returns true after completing the other ready future55.+ // the remaining task can not be completed52/ assert!(!pool.try_run_one()); // returns false<666NK This function will not block the calling thread and will return the moment6TQ that there are no tasks left for which progress can be made or after exactly one7PM task was completed; Remaining incomplete tasks in the pool can continue with896 further use of one of the pool's run or poll methods.8SP Though only one task will be completed, progress may be made on multiple tasks.\9 B3 93 ;$9$9;<<<<;<GGٴ۴ܴݴ޴ߴ}rUH#@JG Runs all tasks in the pool and returns if no more progress can be made@ on any task.A>>>=>GڑN9LN  l<==>8}OB3 N3N$NDNStS  B3 S3 @$STBBT -,US--jh-L|,fhoa$0cd,ce|$Dr# Represents an executor context.;8 For more details, see [`enter` documentation](enter()).,P[.gtL,cff GD An error returned by `enter` if an execution scope has already beend entered.T IiL,chh kgk8  ggg cg cثq1ȡ#Bj j k$  mgm8  ggg cg cثq1ȡ#Bl l m$ % +EB Marks the current thread as being within the dynamic extent of anl executor.JG Executor implementations should call this function before beginning toJG execute a task, and drop the returned [`Enter`] value after completing task execution:<! use futures::executor::enter;&# let enter = enter().expect("..."); /* run task */ drop(enter);<*' Doing so ensures that executors aren't -* accidentally invoked in a nested fashion. \  # Error  OL Returns an error if the current thread is already marked, in which case the 63 caller should panic with a tailored error message., 9B6 oppppop7 a9U rgr 8   ggg cg cثq1ȡ#Bq q r$   t#t $   Bs s t$tuuuutu7 U d|44$4+)$444@>44B? A single-threaded task pool for polling futures to completion.KH This executor allows you to multiplex any number of tasks onto a singleLI thread. It's appropriate to poll strictly I/O-bound futures that do very'$ little work in between I/O actions.B? To get a handle to the pool that implements [`Spawn`], use theEB [`spawner()`](LocalPool::spawner) method. Because the executor isOL single-threaded, it supports a special form of task spawning for non-`Send`PM futures, via [`spawn_local_obj`](futures_task::LocalSpawn::spawn_local_obj).L`\c5:{| 3$ zz###"#"#"Y> D zzIII -I-I-ZvH#"d ~g~dd  ggg cg cثq1ȡ#B}} ~dd  :7 A handle to a [`LocalPool`] that implements [`Spawn`].d Ƅ4 D 00%0 -0-n?QQ"  B   g  ggg cg cثq1ȡ#B  g.a,&ee*B3e2Oee 5!e3"Ne"e gg4gfgf~[l(*[,ZQN An iterator which blocks on values from a stream until they become available.t[۵ [4[,[Ћz`%9U-/L[4[Q+۵vg[gQ+Q+  ggg cg cثq1ȡ#B[ Q+Q+d.a<>cc 2eca63egLee cff4ffff 8< ra@eg>ee caPVd+nt3 0-S*6$J & NN,2Q+?     / 3O thread pool spawn_okThreadPool::spawn_ok9https://docs.rs/futures/0.3/futures/task/trait.Spawn.html>https://docs.rs/futures/0.3/futures/task/trait.LocalSpawn.html  C z spawner()| LocalPool::spawner)futures_task::LocalSpawn::spawn_local_objfutures_task::LocalSpawn |z|  ofenter documentation  ####!!!PQPPQEM  ""  ####!!!PQPPQ LocalPool poolincoming LocalSpawner @cannot execute `LocalPool` executor from within another executor@BlockingStreamstream,zzL]M-t~?7"^n _Ï4g,j䀀&xࡥֹ>ByS urBnF{F?4sFul )Gu]8j.74l` cs"ѮadHWjKX#'!x܎! Rfih`D>lVBVgSn2X7Q,*0@Ig;dOkX8mҕxs2O¡?(ц3+ʹǵBľ6` 1rP9 bm( G&s63z?hUs, 7t#mg֡x,0ERsq46,w%7IgvLAZ )>B ({ wpxD=#~u6o_;N5{Mנt{Xt1DSAwh0|z{<g[b;MRu4cS@RP}-ZJ'pC ׊ֻ F$\Y̿`jXpxsAȣeL:uNsؼ`"sE$9#½b:]!2/_(l5+.6z}}&Z!Y'72R9TR zGk(ssZ/|mC#~ Va_5>wmd,Ͷ3?AD-SUJZťo tNB a*7skBgE!l(Jl=?/q_Fɠ^t54 v1yuB m^9 Wѝ(|ŎÒ[T\~ƽ[ly C;f>:Ax\vv <=@aF'4Q=\=????????@ @ @@@@$@,@4@;@B@E@K@R@Y@\@b@i@m@p@u@y@@@@@@cAAAAA2BCCCODpDD`EHqHK"LQjRUVV9WSWWX:YZZ[x[[$\i\\M]e]^Y^{^___P`````` a afakaqab2bbbbccld~dgAh\h i#iriiiij$ jl=mmmdnn(oEooocpzpp"q\qq!rrrQsttTttuju<w =;aAA[DEWZ[U\#]e^_bbbcxdMhilmn6oor5s                 <u=@iAAAAJBCD)EG]KQU&VWkWX;ZZ*[[\Q]}]^^_ `h`9aabbb ccgth;illAmmnn\oogpp@B@H@N@U@Y@_@e@i@m@s@w@{@@@@@_AAAAA-BaCnC{CCCKDlDD\E HlHKKLQeRU VV5WOWWXX5YZZZZ [s[[[\X\e\\<]I]`]^U^v^|___K``````aacahamab.bbbbccgdydg=hWhiiniiii j jl9mmm`nn%oBooo\pspppqVqqrrrrAsNsst*tNttucuuuuuuuuuuuuuuuuuuuv vvvv$v*v0v6v]M]e]^{^__P````aa5afakaabbbbcg\h#iijjll=mmnnEoocpzp"qq~rrrCsQstttjuuuuuuuuuuuuuuuuuuv vvvv!v'v-v3v9v?vEvKvQvXv_vevlvsvyvvvv@qAAAABvBkCxCCC2DWDDMEGNHKKLQRUUV&WAWzWXX/YXZZZZ[a[[[ \9\b\\]F]Z]]C^a^e___4``a(bbbbccPdtdghIhhi_iillKmmKnnn2oooEpopppqDqqqrrrsKsst&tEttt\uu@kAAAA BVBeCrCCC DQDDAEG%HxKKKQQUUVW;WrWXXYEZZZZZU[z[[\&\\\\\@]R]]7^[^Y___(``a bbbb{ccDdndggChh iSiillCmm>nnn,otoo7pipppp>qpqqrrrrEss t t-thtt.uu@sAAAABPCCC6DYDDQEHRHKLQRUUV*WCW~WX3YZZ [e[[\S\\!]^]]G^c^i___8``a,bbbbccTdvdghKhhiciillOmmOnnn4oooJpqpppqFqqqrr3sst(tJtttauukAALBCD*EG^KQU(VWlWX<Z+[[\~]^^_ `i`abccguh<ilmn]ooprisANBCD*EG_KQU(VWlWX=Z,[[\] ^^_ `i`ccguh23BZCCDUEHKQUV.WWXZl[\\]N^m__<``cXdghgiSnoOppsbHqruu<o=cAAOD9WZx[$\\Y^_3aabbcldAh ilmn*oo|rrA bblnruAablnrZ]dho*1@DVipw{$(.=DH^eipw~ # ' + / 3 7 ; G K O [ g x     ! ) - 5 Q t y ~   ! ) . 6 < B H O V ] d j p v |     ! ' AbblnrAcDdDeDfDgDhDiDjDFWZZ[V\&]+]0]g^k^__bcNhim8oo7svwxyk#ypMtAkDKWZ[W\5]o^_bcxdShim=oo9;eaY]cydddStderr Mw F+KKKK 7K7K736"*KKKK 7K7K736##ReadyToRunQueue#<"#head"#tail"#stub"gy("$$$LeakQueueOnDrop$" ]_%H [$V=4KKKK 7K7K736Inner idparker}%yhhhhSystem /I)22 UnsafeCell2.\*="!11Ref1.1 .?3 *r!11RefMut2.2 .2 .뜿Er!!řǙșəʙ˙G*R{9  řǙșəʙ˙G*R{9 ÜĜŜƜǜȜ_w 77#7 6wQ?m!؆ 00%0 -0-n?QQ! "!*88%8 787=֍B88%8 787=֍B88ArcInner8strong7878data71%wxd888787871%wxdBoxljk# MaybeUninituninitW췜--RcInner------6>)\!"((RawVec+,,XՔ"777Os7677Simple7677 SimpleMessage7677Custom76VN7O CustomOwner6 fD>>Drain> tail_start=>tail_len=>=>=KRgq"Adapter,errorqA1??? DropGuard?> k,h~(R"$$Bomb$queue"$task"ss*e11 BorrowRefMut1 ."> >>DtorUnwindGuard 4~ >g*7 U  o667 7776767 error_drop67 outer_drop6*I]@DU 6 67U g*######g*g*711 67 67 W XW_###0!"aF"$$$$$$.!"00M"M"::"C"88.!"999"9"9"9"9"1!1!P?"$$"#R" |~ ^|?Sw ""0! ?"?"$"$/!:":":1!::2!#f*\ \ \$`$`E"E9"9"9"/!":"1!11#ff100 WeakInner0-0-Mv1N     q,} core_intrinsicsfmt_helpers_for_derivegg,z'+ ],zf!J6$crate::thread::local_impl::thread_local_process_attrswGa3$athread_local_internals,z}|5 \ҕxbg[b;MیŁjXpxϖ m^96z}}TR zx܎! Rcs"om""3A $7=3W"%ZjX|"J0~'SR{Q¡?(цdক)*C )>BuE$9#ٜq46,wq!Y'72RD-ȭ=?/q_͵ 1rPg+X2cE/3,?4s s2Oc63zk%7rO8åu-u6o_yRu4ceL:u{<D=#~x;>'4 v1*0@I^vLAZt>ByS )Cb0ȷ#D),0ERsp C;f )Gu]8>:Ax\\dOK5WzL]M-i]L48sNw#ܯ QyX22X7Q,]S@RP?hUslOZ(RA\ZEKT[ ]i%!2/_(l4l` Ѯa4#bqs S`!F E`?6g;dOk_̿`ꍕ½b:]SAwh0Va_5W?j>WHj@Gk(s٠m71#"SnlV7skBgd*_us, #<#(HWj~h[Be\Z;:T [t&xࡥֹN"];;'4g,jX`pCFɠ^t5&SSMIgs8ma4k^&~Y?PH4Jwmd,ے=UyuB i`DL*M L( 5{GisL&Z_<& g>LyVd\{%=z !l;)df(PL'hS:/}O?rL$)1q9R.N_,mt )"l6`NyF. o9,>\!CWdd~f@F-x=?sFH lk+3pU?--iM5 a3}$fH*, aa26yb?<0ua:cJ<_w9xa/=],!Qdtr(rF0H {Gis]/root/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/futures-executor-0.3.34/src/lib.rsR/root/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/futures-executor-0.3.34]/root/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/futures-executor-0.3.34/src/lib.rs lmcwC,I*EG@@:0NONO LN  LOOHP(K0`q  @?/'a 7  7= cLqPL<d/root/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/futures-executor-0.3.34/src/local_pool.rsR/root/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/futures-executor-0.3.34d/root/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/futures-executor-0.3.34/src/local_pool.rs D7@r.ii"")(N,%!$ !CLM(CFPQ9;;!&GIJL;N#* +GHHB>H,& M K!;1.21"KOKP  ._+M:,A1 *)WX QJ.I *)": OOPNBE'7760( YT **/)&111=VT37 SYU>X,'6 G+D)8:$U*/ O **/)&1110/" SETT/*5"0".$ FHHI0@#:E43=7 9#7)! 6NN0+,HNLR/6'93,D#9/74 T:7( 1/( #_:0( 7/( v!U,ud_/root/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/futures-executor-0.3.34/src/enter.rsR/root/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/futures-executor-0.3.34_/root/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/futures-executor-0.3.34/src/enter.rs F?J̟HqQPM$<H !?.#?A)FKK"'+. P7.*$ ?) ,sC$c*5VEx86_64-unknown-linux-gnuO&)w0+futures_executor-3f949a2e8a2039f5,z  ddgd0<&&&rust-end-file