! / 0 0 0 0 8 ` // 64 ` futures-328a70e7bc2bb132.futures.f2d79cb7e8794385-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_coreC-U,q}-a08f9eceddc04eb71 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_utils20"d-295b8d78b7c91d4a futures_macroݴ $k\c-2d875dffae9f3cf6 futures_task:Kkt݀-128f12bebb0b2696 futures_sinkif٣dx-04ec0352964b17dfpin_project_lite#^*xVC-078d79a159585fd4futures_channelN ɰ+_-b9a1f469600c1287slabt=QDZ[-16f6668050970f4d futures_ioi ܩe`% < -f0bb37989624a613%(Q|;iz-f44de480fcddb292futures_executor̭Q@+O&-d773e40eeb1be500. 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  ####!!!PQPPQCy跜l 3y?L"3J3:sN$U 9 z| G^#t&κuidԍ$R]l ZQuw%1qaܞ9 '&/Nlr.~R74|՞`3D(w2)6nJ($r{FvZ/}x2נ-y:Xc)+D鼔 ̢ﾴ%ebj3բ' L2-%ŜEpřoo> Aܟ,uO/v+)06t=՜L=fo׏ 9bT_>ʙG%b$ur% YߩQ594=+5,qBF\该(JUIY5E dYGxuRhD4{}fh$ |Q24ڲOgM8b3?Yê!ks  !^n1~7;QcXz Ҭ9J aj%꫊i-zw54beD2jŐkMh`!~eT&zCmݳbBvO|b|D˒GИ50(ޏ;Ś*Y8NJ&cLNsoS?V7R1م%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"% Cy跜Z`*VA AA1A!AFA ODHT U;QcX>D29J @Rh1O/v+) w5C8NJ&cP YߩQ)oS?Rks :uidԍ$ 1Tl 3׏%^#Ś*YOR]l ZQ $ur%(gM87V7RSt=՜"LNsQh`!G 9bT_&(w2)h$ 4b3?84ڲO65,q,aj%A~eT&zCHt&κ (JU.FvZAܟ,uNlrBF\该- ;ebj3jŐkMF594*Cy跜D2Ey?L9 '&/06!z Ҭ?c)+D鼔%ŜE>ʙG%b'˒GL"3J3' L2-:sN$|Q259 z/}x2נ-IY5E/ dYGxu01~7=U (ޏ;N1qaܞ 4beDi-zBmݳbBI#| Gy:X.~L=fo$И50M6nJ ̢ﾴ%přoo> Yê!9($r{`3D=++uw% !^n<vO|J4{}f3R74|՞b|DKNbt`](FlIJ,()lc{'8U!]R-~_jDjyr[JVJGlyPZ=M:iO}=!m|YB_D="hFr>`OQNbt`](FlT/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@'@IXڸ0hXsHx86_64-unknown-linux-gnu. F qpcfutures-328a70e7bc2bb132Cy跜 cU9U9U9UUrU9rU//^Nrust-end-file.note.gnu.property.shstrtab.strtab.symtab.rmeta@ .`K&HL`LaL5lib.rmeta-link/ 0 0 0 644 648 ` ELF>@@GNU>futures-328a70e7bc2bb132.futures.f2d79cb7e8794385-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.f2d79cb7e8794385-cgu.0 O@0@-m(p0