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_lock=!,ېQU-b516199872fb7c65tests,_$_     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@@ A(gxDEF GH IJ KL ]1j  ggrg#tmE?,Fgg  Δ`tIp99: < C _0:8B@NDMDPDQD&+@35D1=9@  g# KKKK 7Kphantom7K736  K1 FFFGlobal ě + ( @C)4 >' 2ZdO(O#. 8AK('.6 PX mu=Z gRÜĜŜƜǜȜ_wĤĤŤError :Mlt ggg cgbufcثq1ȡT== "- %``Va`68Rt\> D>$> 14>\> D>$> (4>4> 4> == r T E=y> \> D>$?(4?>  > ÜĜŜƜǜȜ_w  {?"==$= ,== ~ ">GFݱ}LK ? !old68TAA'4A A$A ^3dA\A DA$A(4AA3A#@d $A,A  =]3#TBB'4C B$B#Z/dBlC DC$C(4CB5C$Bg $B,B  =]/#TDD6 @D%Ci\C$CZ3THH'4H H$H#Z/dH\I DI$I(4IH3I)Hd $H,H  =]/#TJJ'4J J$J#Z/dJlJ DJ$J(4JJ5J*Ig $J,J  =]/#lN DԿN4N 0$N1NN.NCN LNu6.}TOO'4O O$O#Z/dOlP DP$P (4PO5$9l$9l ?ԨP .\P DP4P.$P /PP/O O.LO.|  d6Vx#X1.LQ TQQ'dQ$Q,Q4Q4Q Q+$Q Y 9QQ2$Q R4QLR |R 'TS|S'   66TryLock8 is_locked9kTřǙșəʙ˙G*R{9 Wakerwaker3e]4S 4S S1S 6 6J; S!5 S TS  Locked"lock#order$_pV9Ρ 64TlT "9) !($T X7Q 4TPTT $T 74T dT$T 9= #$T \T$T ;4T U S U X Q9J|z0tQSTnQ.LQ,QT \y: \RřǙșəʙ˙G*R{9 9 6   96 6  9&7p957`#9> old_statelocked! 1* 4`528::;&<979lY DX4X.$X/XY2X>X.LX\w:.|] 9:'99: < C _0:^ ho9:@D,Future4 PinKK AtomicUsize\4   $: $ٴ 6, 5<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"),LW< }); // Our sending taskSGD // 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...WLW" // They want it, let's go! tx.send(Expensive);<Y # fn main() {}< ```5https://docs.rs/want/0.3.1l9:@Db c ,C\  [ DW KV KDJ I  \   I : H ٴ 6G  5F 6ORUDL:D-lt # L $       Create a new `want` channel.B -* An entity that gives a value when wanted.,r,! An entity that wants a value.,tmE?,F2,52 The `Taker` has canceled its interest in a value.4Δ`tIpT4ԖԷ$B   $ B num d","K1 ",""$"6T" "#$%#G#KH Returns a `Future` that fulfills when the `Taker` has done some action.$#X XXB # $#'#-8vv84i##iÜĜŜƜǜȜ_w#i8$iiij(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 Zl6 local_wakerext_marker_marker28}[ٴ۴ܴݴ޴ߴ}riB ( $)cx)2 !!!! ! 7U  l6oooo8}Ԃ=;>; 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 FDtGGEtG0uTHb bB( H( )$HI!IFv\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-.$QX2#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: < C _0: C _0::<  B+!wB99 : ]l]99]8rr>??\^4^==i^S$^stuD [$V=4 s tl6oooo8}uٴ۴ܴݴ޴ߴ}rB= ^= ?8$^p^Đ A cloneable `Giver`.IF It differs from `Giver` in that you cannot poll for `want`. It's only%" usable as a cancellation watcher.\(gxA,@@ CC  S SBBB C T,]1j EFGHIJKLFHJL$DDDD$DDDD$DDDD4DDDD    OO  T TBNN O   RgR  UVW U Vggg cgcثq1ȡWBQQ R  "&  S ) )&+0 5 : E@EF; K P0 U K[Ka f kO pu3z YY [[*] ^^(-7 Giver::give     ####!!!PQPPQ6ClosedGiveWantIdlewant called after cancelޕ{@B^P9SxVUFq%2:/a]4VݙdXlМ3rj DUhNݣRA ?_L _{A'|"vqtReig%gROMoL2 O 0="KܩJE*ߙ,R{͙C.N[f~65"pW `3v;]߱ a+u:q6jlfr<|`H3iao|{4zAxDYC.Zy0(o׮&ޘGLJ(0 o!%ݔ]\C e':k(0zxnlLȺDḖujѹū9?o8V'E:)b'Sq8DrȰ$v޼ FsAoFs*Tsd5еiV%( )nFSO 5 }Zs5#g9p!Yqw]bPܤ g33 @pt+xΖk#MSԲ31oWVrB(9=D TfE4A ,wsMk_n6C?ڈ`d"l*c:J|g$o=LCHhd){c đfvDc,Gbxf 7Q44;J=J>J<J /M" 0000#0*01090@0C0J0P0W0^0014111 2$2>2{2223313O3 4e829:D;;M>>?e@@@!A<AAABBCCCDDyERFiFFFGYGGGHGHbHHHH /F1120222=3Y<= >>@-AABjCCMFwFGGGGCHUHHH ' ****/00 1e1112V222333C79;;*<<p==2>?/@}@@TABB CCC D6D.FVFFFGEG]GGGGGHyHH"00 0000&0-040<0@0G0M0S0Z00101112 2:2w22223-3J334a8.9:?;;I>>?`@@@A7AAABBC{CCCCDDuENFfFFFG-GUGmGGGGGHDH_HHHH}IIIIIIIIIIIIIIIIIIIIIIIIIIJJ JJJJ$J)J/J5J0000#0*01090C0J0P0W0001a111 2>222333+79:;<h<X==>?@e@@>>?Q@@@A)AAABBBCCCCDYE5F`FsFFF'GOGgGGGGGH?HQHHHHhI00"1f1112&2_2}222333334<8y89$;;3>>?E@@@A#AAA~BBBCCCC DME/FXFmFFFGGG_GGGGGH9HKHHHH[I01.1n1112.2k22223+3;334L88:4;;?>>?U@@@A+AAABBB!CCCCD]E7FdFuFFF+GSGkGGGGGHAHSHHHHlI00f11W22233D79;;+<<q==3>?0@@@UABB CC7D/FFFGGGGHzHH0W223D79;;+<<q==3>?0@@@UABBkCC8DFzHH0B223/7e89:;<l<\==>?@i@@@ABBC"DF1GqGGGeHH(Yc0a  g=39 2 )! e;17 '!  f<28 (!! C0o223P8:8;;C<<==>?Y@@AABBfEFHpI1/0_11$2{2213M<==>@!AABCC(FkFFGYGGG7HIHHH1}122`CFFF1p112SC9FF "&*.26:>BFJQ]iu| ,07;BIMTXely} +/6:>BIMQX^djpv| $*1122cCHFFGGG122C3D3E3F3G3H3Z<== >>>>@.AABCCxFVHH?J~J4622I3_<=>>@3AABC}FCH[HHH ',46?fg<969622 UnsafeCell2.\*="6688Weak8 787=֍B 88ArcInner8strong7878data71%wxd7aaa666W7W89ˆ"C)6-616::\ C9Ϝ: e,}Vcore_intrinsicsderive_clone_copy_internals{@y@` V]{@[1E$crate::panic::panic_2015"T]8llibstd_sys_internalspanic_internalsrt%%{@4`{e,{@{]{@o?Sh)q,} fmt_helpers_for_derivegg{@L\kG#-p {@oŤ   {@Z`*o$u  {@V" O  T]{@I3:P$crate::assertT]]generic_assert_internals{@ 6|x debug_assertO͜S]{@﫽kjgggggjjojggh jmihk5i&h2jijsjhih"jihHk]iyh[jikj%iiODHT wa+8?ڈ`m8L@ \ O 0=.O 5 }ZsZxf 7Qv_{A'|)Xerhd){crDhpܖE Yqw]]$p NΖk#Mc ~$, g%g,]'_:k(0F(9=gt+xbc,tUΠv-R /pZy0(o@ `3v;6q%2:/a:)bN]/k@= C ūW@j Bq ^öB8:  DUh$ TfE4i"IN/`Kvgz(L4zROMoL2-=LCHqS1!SxVUFV'EMеiV%WݙdXl"xDYC.>B^P93iao|<GbuN[f~64lfr:|g$op đfvDsd"l*cnyslTk_n6Cl31oWezxnlLGo!%CVrBf9?oKsAoS*Tsd5U)nFSYA ,wj8u\7"vqt*$vQ{4zA={@<|`H;@pab^LJ(0 B>]4V!'Sq8OsMku`1m". &/_?Tg)87DS1!KBY4@'N=$Z@" 6gP>S7"1*l+W!\T)say\Tr$ZTU&1BoxP`D,HbUTqL5._"}/C|3no\I_X_ 4mA~.9(>P/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-+- [Q[~.yx86_64-unknown-linux-gnuhsߖ>D, -321384242e1cb677{@ NwN  ``ASSSBSBSERwSwwwSSSSSSRS;vSS;vS&REEwLS @R $F( P**!rust-end-file