rust #rustc 1.98.1 (48a229cea 2026-09-01)m6GÂn62-64f5f36fb0927694RL.SAwjL-df1bddb45adbe94b1 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-549498e8b2e4d924try_lockrDx1-c54c4731fcd59337tests,_$_     GiverinnerTakerClosed_innerInnertaskwant  poll_want give is_wanting is_canceledshared&( ( +-cancel- -signal13 5 7Want9 9'a9 ==  SharedGiver@ BStateDIdleE D G DGiveI D K  NQC8O8R8R8R88 8 8 8"8#8$8'8'8'8)8*8,8,8,8.8/8082848484868686888=8?8?8?8 8@@ AD|h DEF GH IJ KL ^qk= ggOpsg#@Zmwgg  Dp_\99: < \|Ej8B@NDMDPDQD&+@35D1=9@  g#  KKKK 7Kphantom7K736  U`m1FFFGlobal ě + ( @ C8C MA Lisi(O#. 8AK( -4; W^!u|?] gRÜĜŜƜǜȜ_wĤĤŤError :M| ggg cgbufcثq1ȡ <, \7T$ 9$#b99: < \|Ej#- L# \ =E%b 3f*ہ88ArcInner8strong7878data71%wxdM'  i A  % ``Va`68Rt22 UnsafeCell2.\*="```Align8`` x:B+}M   F  a 9)GFݱ}L9Á!9́ ? ?? Ӂ >>!ÜĜŜƜǜȜ_wt> ##*"==8:=9=b|bEb'Ceb04>6m.4>^ ( =y `   2 )  >  1  4? $= ,=#8 #g'[#c՟bT   可 Wold$7  A. dAi'$ ߮!  aS !)8 A3  AA# @d :A9ɭIA2  @4Aq ; $A',Aj)(e33) Bz 3dBLol)G ) !=q:pB5  CC$ BgA:B=9850 0,)%6-02  l4C  g $B',B )(3))TDD6 @ DD%Ci\C$Ch3 H  0   dH% ") )E !'pH3  II) Hd:H9 -z2 tp l"4IE   $H,HL )(G3)) J  \   dJ.Q N)) )q !SpJ5  JJ* Ig# :J 9      -  2     N 4JE  I  $J,Jx 1)(s 3))ԿN  0$N lNNN.NCN LN /;P ;$P \PPP/ O8 :O4 9/ , '' #   - dO (  2     d 4PE  _  O<LO  ?$9l;c) LQQ+'1 'dQ  #  i A   3  6  ԫի֫׫ث٫ګ۫ܫGݫޫ߫F c1    XX S1|S'1 ';66TryLock8 is_locked9Q}řǙșəʙ˙G*R{9 Wakerwaker3e]  C+ !4S !4SS! Sm S  TS  Locked"lock#order$_p9JciɭClT }9  CY222.\*="C2 C &  C  TT $T    D4T     XR U  , Q U  m    Q9  %a QLR|R T$T " RawWakervtable .  K RawWakerVTablewake wake_by_ref>b L)}   T " u4  0$_QSTn:Q9 ',>FX`4QE   Q   2      a& `4Q:59 ',>FX9X-C2C-9nXD4TCnͣ>EdT4T4o}D_~D͇5}U9}DU8~ DEU} 2DU."D*"Q<LQ,Q  L \RřǙșəʙ˙G*R{9 EN FM ECrDE{/z1f   ( z1G9FM9 GlMLL>C old_state locked  ~  Dj EDEA` AB 6 AB 7 AB 7 AB 7JEMX ;$X lYXY2X>X<LXf3;|] 9:'29@    9:@D,Future4 PinKK AtomicUsize\4   $: $ٴ C, B<6DA A Futures channel-like utility to signal when a value is wanted.MJ Futures are supposed to be lazy, and only starting work if `Future::poll`IF is called. The same is true of `Stream`s, but when using a channel asLI a `Stream`, it can be hard to know if the receiver is ready for the nextT value.NK Put another way, given a `(tx, rx)` from `futures::sync::mpsc::channel()`,OL how can the sender (`tx`) know when the receiver (`rx`) actually wants moreIF work to be produced? Just because there is room in the channel buffer85 doesn't mean the work would be used by the receiver.MJ This is where something like `want` comes in. Added to a channel, you canOL make sure that the `tx` only creates the message and sends it when the `rx`2/ has `poll()` for it, and the buffer was empty.l # Examplet ```nightly  # //#![feature(async_await)] extern crate want;ܞ # fn spawn(_t: T) {}1. # fn we_still_want_message() -> bool { true }0- # fn mpsc_channel() -> (Tx, Rx) { (Tx, Rx) } # struct Tx; 0- # impl Tx { fn send(&mut self, _: T) {} } # struct Rx; SP # impl Rx { async fn recv(&mut self) -> Option { Some(Expensive) } }  1. // Some message that is expensive to produce.  struct Expensive;  )& // Some futures-aware MPSC channel... *' let (mut tx, mut rx) = mpsc_channel();   // And our `want` channel! '$ let (mut gv, mut tk) = want::new();    // Our receiving task...  spawn(async move { >; // Maybe something comes up that prevents us from ever '$ // using the expensive message.T  // >; // Without `want`, the "send" task may have started to@= // produce the expensive message even though we wouldn't // be able to use it.%" if !we_still_want_message() { return;L }96 // But we can use it! So tell the `want` channel. tk.want(); match rx.recv().await {41 Some(_msg) => println!("got a message"),%" None => println!("DONE"),Lm< }); // Our sending taskjGD // It's expensive to create a new message, so we wait until the30 // receiving end truly *wants* the message./, if let Err(_closed) = gv.want().await {41 // Looks like they will never want it...mLm" // They want it, let's go! tx.send(Expensive);<p # fn main() {}< ```5https://docs.rs/want/0.3.1l9:@Db c ,Z\  [ ZW KV KZJ I  \   I : H ٴ CG  BF 6ORUDL:D-lt # L $       Create a new `want` channel.B -* An entity that gives a value when wanted.,Ops,! An entity that wants a value.,@Zmw2,52 The `Taker` has canceled its interest in a value.4Dp_\T4ԖԷ$B ]  $ B num d","U`m1",""$"CT" "#$%#G#KH Returns a `Future` that fulfills when the `Taker` has done some action.$#X XXB # $#'#-8vv84##ÜĜŜƜǜȜ_w#8$(S$FC Poll whether the `Taker` has registered interest in another value.%%JG - If the `Taker` has called `want()`, this returns `Async::Ready(())`.%B? - If the `Taker` has not called `want()` since last poll, this&JG returns `Async::NotReady`, and parks the current task to be notified&*' when the `Taker` does call `want()`.'FC - If the `Taker` has canceled (or dropped), this returns `Closed`.''FC After knowing that the Taker is wanting, the state can be reset by(" calling [`give`](Giver::give).L(YZ[ Y ZlC local_wakerext_marker_marker28}[ٴ۴ܴݴ޴ߴ}rB ( $)cx)2 !!!! ! DU  lCʅ8}Ԃ=;>; Mark the state as idle, if the Taker currently is wanting.<<74 Returns true if Taker was wanting, false otherwise.$=\ \B = "$=@ ?DA Check if the `Taker` has called `want()` without parking a task.??EB This is safe to call outside of a futures task context, but other@0- means of being notified is left to the user.TA] ]B A #$AB!AFC Check if the `Taker` has canceled interest without parking a task.\B^ ^B B $$BC"C'$ Converts this into a `SharedGiver`.4CB %D'g'D8D_`a _ `ggg cgcثq1ȡaB& D& '$D EF)*H FDGGEG0THb bB( H( )$HI!IF\Jc cB( J( *$JJ,g,K8Kdef d eggg cgcثq1ȡfB+ K+ ,$K KTL./0ĜNL41 Signal to the `Giver` that the want is canceled.MMC@ This is useful to tell that the channel is closed if you cannotM drop the value yet.4Ng gB- N- .$NON1. Signal to the `Giver` that a value is wanted.$Oh hB- O- /$OQ"4Qi iB- Q-;$QO"X2#2X$Xj jB1 X1 2$X̛Y4g4Y8Yklm k lggg cgcثq1ȡmB3 Y3 4$Y Yԃ[6g6[8[nop n oggg cgcثq1ȡpB5 [5 6$[ [T\8\,\q qB7 \7 8$\!$] ;;99: < \|Ej \|Ej:<  BK"wB99 : ]l]99]8rr>??\^4^==^S$^stuZ [$V=4 s tlCʅ8}uٴ۴ܴݴ޴ߴ}rB= ^= ?8$^^Đ A cloneable `Giver`.IF It differs from `Giver` in that you cannot poll for `want`. It's only%" usable as a cancellation watcher.\D|h A,@@! CC! ! S SBBB C! T,^qk=EFGHIJKLFHJL$DDDD$DDDD$DDDD4DDDD    OO  T TBNN O   RgR  UVW U Vggg cgcثq1ȡWBQQ R    % *    h ) )       E E R    H  K K 9    l    R Y Y  [ [ O ]  ^ ^ (-7 Giver::give     ####!!!PQPPQ6ClosedGiveWantIdleӬEodq/.@80#(bWPDۺsʂp>O{3r˗&E|Kv^;nzݤw<-ȿ`қvAo@ չ'ߪOh^<;mW7_,md])<>F& NUq3C-5մPǵ垳#E#{!PVo9[^4Ʋ[+PV!X ߦ?7q3A a= QP әndz>mk; ~`ß|IIV{f#04#ks-83%ΥBOU\6NA с)@@3)XD{Cgl; (hjb'O55[g)Zkc5!^%xDtt ˇmXI۹@d~ ) x_p0O*6K) d3:H4RIK2w,6ܿ$׷X2nGpu7/ b:iXfKh X r4#C2;QwKL5_lo_E0kj {M"vkdi$fK|@r02&UNKԲd\BU稣}t&?QyI'wOl&2NXTYH K  Z^X4nO,\mUaΤ3pK0r <S&1O%I%_r{0rc<%$V<׭ax z}!^ JM¥tMRγ/(Q-" ўtn͗Z &5HqР{\*źPe!ΘcD6Kyb| cMۯA#ִ}Wvof5{PYLX??UUUUR :M.K;O;V;];d;k;r;z;;;;;;;;]A>Y>q>> @CyD[EF(GGGVHlHHJIeI J#J'KKLLlLL.MIMMNPNO%OQOjOPQQQ!RjRRR*SiSSSTT-TI :BRX<<H=q==;>}>GbHVIJLxL:MMN;OQQQRXR_RfRSST T ' ****H:;9E>]>>B&EVFFqGGHI}IJzKK7LLaMNVNNOUOOQQQ'RnRRRRRS.SVSSDT-B;H;K;R;Y;`;g;n;u;};;;;;;;Y=>U>m>>9? @CuDVEF#GGGRHgHHEI`IJJ#KKLLhLL*MDMMMMNNO O!OMOeOPQQQRfR~RRRRR&S>SfSSSST*TTTTTTTTTTU UUUU"U)U/U5U;UBUIUOUUU[UaUgUnUuU{UUUUUUUUE;O;V;];d;k;r;z;;;;;;5<]<<<%=M===>A>Y>>mBE>FFYGGHHeIJbKKLLIMNRNNOOQOjO{QQQ#RlRRRRRS,S@SS-TTTTTTTTTUU UUUU&U,U2U8U?UFULURUXU^UdUkUrUxUUUUUUUUU;@O>g>y>*?R?CCGEwFGGG;H^HH6IRIIJKKK LYLtLM6MMM>NjNNO7O^OPQQQR/RxRRRRR S8S`SSSS TTT;:G>_>s>?@?CC;EkFGzGG/HXHH*ILIIJKKKLMLnLM0MMM2NYNNO'OVOPQQQR)RpRRRRRS0SXSSSSTTT;B%>S>k>{>.?V?CCKE{FGGG?H`HH:ITIIJKKKL]LvLM8MMMBNlNNO9ObOPQQQR1R|RRRRR$S>??B'EWFFrGGHI~IJ{KK8LLbMNXNNOQQ)RRRSXSSET;==>B'EWFFrGGHI~IJ{KK8LLbMNNNOQSET;==>qBCEBFF]GGHIiIJfKK#LLMMNNnOQRRSBSS0T(Yc0a $P26+2  y, "N04+w,  #O15+x,,  N;=>2?COEFGGCHH>IIKKKaLMMFNPRSTq>GVHJI JLlL.MMPN%OyQQ!RjRRR*SSSTTQ<<A=4>NQ@RD<<4='>NQ3R "&*.26:>BFJQ]iu| ,07;BIMTXely} +/6:>BIMQX^djpv| $*S<<C=6>NQJRQRXR_Rr==>>>>>>GdHeHWIJJJLyL;MM=OCOQS!T,,,,,,,,,,,,,,,,,,,,,,,,UU@w==>GfH\IJL~L@MMIOQSST&T ',46?   e,}Vcore_intrinsicsderive_clone_copy_internalsEodq/.@8A*G|]Eodq/.@8[1E$crate::panic::panic_2015"T]8llibstd_sys_internalspanic_internalsrt%%Eodq/.@8ʚu&e,Eodq/.@8Se2ZsEEodq/.@8o?Sh)q,} fmt_helpers_for_deriveggEodq/.@8Rȫ eT  Eodq/.@8oŤ   Eodq/.@8Z`*o$u  Eodq/.@8cBC q  T]Eodq/.@8i&l$crate::assertT]]generic_assert_internalsEodq/.@81n  debug_assertO͜S]Eodq/.@8﫽KtqqqqqqttOtqqqsOskrtsrt{stStrsqtksr(u?s[r;tstxtssODHT wZ k:H4;) d3:dz>m~ ) x7<S&_F&k; ~ ׷X2>w,FnTA a=  r4C-ȿ` 3%&nGp?$HmgV50 NUPVj {Hγ/(Qhi$fKJ<%$Vc@ չ' b'O/@3)X+O*6K9ks-8%TO{3r0# ˇm5˗&w,6ܿ$=6NA с);nzԲd\M-5մw<L5_lF`ß|!|@r02&K1O%`UNKL әn$>YHX cMۯAr#ִsPǵ垳4nO,[d])XI۹@d6\*źPm\m\D,[^4#E#M"vkdIDۺsʂp XBkc52UaΤ3]!Θco<>)@* K Y04#$z}!e!X ߦ?{!PVo9OU\(ΥB'u7/ b@D6Kp!^%x3-" ienI%_raMU(hj.s6< eCUKxiDhSY}=( +qT}%cx5J!17YYH ,dTTz}&Rx-go4Wg=z[S fdNq@nuZV6 ?%x~hzYlTZ(u"_ 28YUt Tz.!1~<i9&5s6< eCUKxiDP/root/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/want-0.3.1/src/lib.rsE/root/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/want-0.3.1P/root/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/want-0.3.1/src/lib.rs t1 KQ+6(ENJM OPJ9NP3!211T2*+(?( ?A& : 5& H405 #$F!)$!!!5"   ."J&6 ! # 9 " PNKOGO/KK'Z>!0#D/AbGE*0$$\57C2&`.?JKC6#2TN](V C<!05 &IJ5'<K(>,) ? 1!IJ5'<K(>"?&1 9H#6C' !)L=b<*) NYY $? 1?! ' &Z 0 & && &+ 77' ,K9C;="@0 $>%+ !( &, 3G D 13 &$#*"$#*"  * *5$!")DC1+<,"2-$!.>&/7XD-+- `߾a9 bx86_64-unknown-linux-gnuĪ-Vӑvw0". -ca77b78bbf81834dEodq/.@8Ќ NwN  ``ASSSBSBSERwSwwwSSSSSSRS;vSS;vS&REEwLSS @R(P**!rust-end-file