! / 0 0 0 0 8 ` // 64 ` futures-20192f6477b0c306.futures.36275f0365f7e49d-cgu.0.rcgu.o/ lib.rmeta/ 0 0 0 644 19992 ` ELF>L@@GNUrust TJ#rustc 1.98.1 (48a229cea 2026-09-01)RL.SAwjL-df1bddb45adbe94b futures_core.. Z-b2e86d4a91990c161 Xr*-1ad4f876c768bda9<%Z>64V`-2d2ab9fb0fe1def5m6GÂn62-64f5f36fb0927694G 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_util` oU1F-9051d6448dad3304 futures_macroi#ujМd{G`-fd2c0a1c627d5f7c futures_taskŇO_SK-9dc53e607663f6e3 futures_sink71G" &h-578a9e470927087cpin_project_lite/+,Dv9O-e9b26d79a08f0191futures_channelv|Lr-4c07352f2b9ac2b6slab;~bౄ9-a4a8269ffb724f29 futures_ioڵC{ҥ*ѳ-0d5040d36e03bfa0.o;_tbݤ-480240aaef38b342futures_executorO&)w0+-3f949a2e8a2039f5. ThreadPoolT< thread-pool;.ThreadPoolBuilder< ')compat4= <      !"#$%&'()*+executor......... 8888888888 8 8 8 8 88888888888888.8Future4  TryFutureL ! FutureExtL  TryFutureExtd!Stream4!E TryStreamL!b StreamExtL" TryStreamExtd"Sink$" SinkExt<#) AsyncBufReadd# AsyncReadL# AsyncSeekL# AsyncWriteT#AsyncBufReadExt|$1 AsyncReadExtd$1 AsyncSeekExtd$1 AsyncWriteExtl$1ready,%pin_mut<%5select4&5join$&5pending<&%  $& ! ! select_biasedl'5"try_joinD'5#future4'h% ,')&sink$'%'stream4' (task$()) stream_selectl(9*channel<)+lock$)1,io**-K.+ Abstractions for asynchronous programming./3NK This crate provides a number of core abstractions for writing asynchronousL code:EB - [Futures](crate::future) are single eventual values produced byMJ asynchronous computations. Some programming languages (e.g. JavaScript)" call this concept "promise".;8 - [Streams](crate::stream) represent a series of values produced asynchronously.FC - [Sinks](crate::sink) provide support for asynchronous writing of\ data.KH - [Executors](crate::executor) are responsible for running asynchronousd tasks.NK The crate also contains abstractions for [asynchronous I/O](crate::io) and/, [cross-task communication](crate::channel).OL Underlying all of this is the *task system*, which is a form of lightweightJG threading. Large asynchronous computations are built up using futures,LI streams and sinks, and then spawned as independent tasks that are run to;8 completion, but *do not block* the thread running them.QN The following example describes how the task system context is built and used85 within macros and keywords such as async and await!. \  ```rust ! # use futures::channel::mpsc; _\ # use futures::executor; ///standard executors to provide a context for futures and streams (% # use futures::executor::ThreadPool;  # use futures::StreamExt;,  #| fn main() {\  # { DA let pool = ThreadPool::new().expect("Failed to build pool"); 0- let (tx, rx) = mpsc::unbounded::();  OL // Create a future by an async block, where async is responsible for an PM // implementation of Future. At this point no executor has been provided 52 // to this future, so it will not be running.  let fut_values = async { PM // Create another async block, again where the Future implementationSP // is generated by async. Since this is inside of a parent async block,XU // it will be provided with the executor of the parent block when the parent! // block is executed.t //SP // This executor chaining is done by Future::poll whose second argumentTQ // is a std::task::Context. This represents our executor, and the FutureSP // implemented by this async block can be polled using the parent async  // block's executor.,) let fut_tx_result = async move {'$ (0..100).for_each(|v| {B? tx.unbounded_send(v).expect("Failed to send"); })t };IF // Use the provided thread pool to spawn the generated future+( // responsible for transmission)& pool.spawn_ok(fut_tx_result); let fut_values = rx .map(|v| v * 2) .collect();LI // Use the executor provided to this async block to wait for the" // future to complete. fut_values.awaitT };PM // Actually execute the above future, which will invoke Future::poll andTQ // subsequently chain appropriate Future::poll and methods needing executorsTQ // to drive all futures. Eventually fut_values will be driven to completion.>; let values: Vec = executor::block_on(fut_values);(% println!("Values={:?}", values);\ # } # std::thread::sleep(std::time::Duration::from_millis(500)); // wait for background threads closed: https://github.com/rust-lang/miri/issues/1371, }< ```QN The majority of examples and code snippets in this crate assume that they are+( inside an async block as written above.66|.8!<SE lb   )  7 V 1s 1 1 1  5 5 5$ %  5 ! 5 !a 5"{ 5# h%  )& %'  ( )) 9* +. 1,A *-  L #!EC  L #!<EC<!!L!S#!SlECl!!L!#!EC""L"""L"T#|###L#6420 geca   7 7 d$|$#$L$V 6420V s gecas     % % &|%% async-await&% d&E&& E $ E,*$ 5 EA?5 a EVTa { Eki{ d't'   =  \  {   (|((E(( |)((t) ))̹)t). *|*)t*A ++)& Built-in executors and related tools.++DA All asynchronous computation occurs within an executor, which is,FC capable of spawning futures as tasks. This module provides several,?< built-in executors, as well as tools for building your own.---EB This module is only available when the `executor` feature of this̑. library is activated.../, # 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 tasks0MJ (which are much lighter weight than threads). Tasks spawned onto the pool0NK with the [`spawn_ok`](ThreadPool::spawn_ok) function will run ambiently onĽ1 the created threads.11 # Spawning additional tasks22KH Tasks can be spawned onto a spawner by calling its [`spawn_obj`] method2MJ directly. In the case of `!Send` futures, [`spawn_local_obj`] can be usedd3 instead.33 # Single-threaded execution33KH In addition to thread pools, it's possible to run a task (and the tasks4NK it spawns) entirely within a single thread via the [`LocalPool`] executor.5NK Aside from cutting down on synchronization costs, this executor also makes5GD it possible to spawn non-`Send` tasks, via [`spawn_local_obj`]. The6OL [`LocalPool`] is best suited for running I/O-bound tasks that do relatively7'$ little work between I/O operations.77JG There is also a convenience function [`block_on`] for simply running a8/, future to completion on the current thread.88_\ [`spawn_obj`]: https://docs.rs/futures/0.3/futures/task/trait.Spawn.html#tymethod.spawn_obj9pm [`spawn_local_obj`]: https://docs.rs/futures/0.3/futures/task/trait.LocalSpawn.html#tymethod.spawn_local_obj**D+block_onD: C0block_on_stream|: F1enter,: o2BlockingStreamt:3Enter,:f4 EnterErrorT;h5 LocalPoolL;z6 LocalSpawnerd;7:prZ\EG-/|AA52 A "prelude" for crates using the `futures` crate.BBLI This prelude is similar to the standard library's prelude in that you'llCDA almost always want to import its entire contents, but unlike theC=: standard library's prelude you'll have to do so manually:D$F ?$F A4FEBLFbCdILLIMLINTIO GE GF H)G HI IJ J1Q K1R K1S K1TlEU4ELO@C\F:$F03lF*4F #lGFLFLG$"dGGE$GGLG;lHHLHLH$"rdHGELI|II0#+)5(@>:-US?LJ|IIJLJ|J7531IdJigeckdKlK'Sinks crate::sink Executorscrate::executorasynchronous I/O crate::io*cross-task communicationFutures crate::futureStreamscrate::channel crate::streamhh%hhiiiiihiijhhhh.iiiiiiij spawn_local_obj>https://docs.rs/futures/0.3/futures/task/trait.LocalSpawn.html[ thread poolZ Cspawn_okThreadPool::spawn_ok spawn_obj9https://docs.rs/futures/0.3/futures/task/trait.Spawn.htmlkk[ lllZllkk[z llZlll!Eb )1111  ####!!!PQPPQ  ####!!!PQPPQe_'6X9tIBZ!ThO#.ks GYo5]|s/H:ȸE&(H]s4v|EġD-sbH*uש+n[zseJiM\Z] Ψ)V߼Z[J$ޚɱpCRnjל\',;u]eW~?}SfFd͓vO>ЈQAc=p94i4+A1Bov4P ξXn1u\ǝQLH-ᯍ2.t˛@ @ᙇV#{[#eYi;ۤ! 6i&o9@ 4CQI6ߙO:Ԅ:_p]K>H?Vi0e=r,G1G:9tַ:l"5nq,?XY[Cƣ5]X4J8lLvv…:_-ѝ${ xeheӉ͢+No}qɾGmʮmcSy](v[suRQy(27=ޘ b/_Ftdܬ}ќ Jҗp>9>~vN**%\QLȒߔ_fz7%R-V0TT $Gj : \    !4!e!!!!/"`"""""##3#H#]#r#####$"$B$m$$$ (%%.'.+./.3.7.;.?.C.I .111111111111242W2~222223(3=3S3333 4R-V0Q-U0O !Cg 7 Y { !1!b!!!!,"]"""""##0#E#Z#o#####$$>$i$$$%!.%.).-.1.5.9.=.A.E.111111111111 202S2z222223%3:3O33334@ V x .!_!!!)"Z"""""#-#B#W#l#####$;$f$$$%M-'.+./.3.7.;.?.C.Q011111111-2P2w222 3"373L3334K4K-O0lovz~ "&59=AEIMQUY`dhlptx|N45-77"% e_'6Z`*VA AA1A!AFA ODHT UX9tЈQ:l"5n7e_'6.t&eӉBo9@ , Ψ! 6i&+dܬ}Mp9seȸE]eW~?Ac=,?X9)V߼=ޘ bJ}Snjל\'=r3tL4P  ˛@ @'Eġ  JN**%\QQQI6.&(H]ߔ_S+NC,G14u\#GmʮE-ᯍ2%y(27I5]X;ޚɱpG:5,;uξ!4C-]|s/H:p]K>0H?V1+n[z q8v…:>CRRQHfFd͓vO>4J8<ǝQLH$_-ѝ?;*O:Ԅ:_/ᙇV#{(9tַ6IBZ!Z[J$/_FKlLv=D-sbH [#eYi) xehALȒRThOi0e2#.ks Xn1"GYo51Bovo}qDҗp>9O(v[suG*u s4v| ${@Y[C:mcSy]Ffz7TJiM\Z]>~vNP4i4+At(7fEThPiRK,^k\9_ w o.OH. NHgj eJ^E(2lqm/= x^$EMI'| qdVk|xcTV?^t(7fEThPT/root/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/futures-0.3.34/src/lib.rsI/root/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/futures-0.3.34T/root/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/futures-0.3.34/src/lib.rs x4k߸_ >, KK/O FN#<G L O0PKM<R9 "`) E1PQ6!QTY"TUT!-(CJ,* M# QUU?) R,  @?/';s3939%FT6  U; %$4.IKDJ4RSRS$PR$PSSLT,O4du X$;?2/H$aQ"9Q:QIB #! O6'6@'@IXt.F{ 7CHx86_64-unknown-linux-gnux}:RY$L~futures-20192f6477b0c306e_'6 cU9U9U9UUrU9rU//^Nrust-end-file.note.gnu.property.shstrtab.strtab.symtab.rmeta@ .`K&HL`LaL5lib.rmeta-link/ 0 0 0 644 648 ` ELF>@@GNU>futures-20192f6477b0c306.futures.36275f0365f7e49d-cgu.0.rcgu.orust-end-file.note.gnu.property.rmeta-link.shstrtab.strtab.symtab@ `N2* :/0 0 0 0 644 624 ` ELF>@@rustc version 1.98.1 (48a229cea 2026-09-01)0.text.comment.note.GNU-stack.strtab.symtabfutures.36275f0365f7e49d-cgu.0 O@0@-m(p0