rust Jx#rustc 1.98.1 (48a229cea 2026-09-01)RL.SAwjL-df1bddb45adbe94b1 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-549498e8b2e4d924Sink  Error  poll_ready  start_send  poll_flush  poll_closeif_alloc!!!$$$$$$!++++++!2222222 8 8 88888888888888888888888888 8 8 8'8'8'8(8)8)8)8*8*8*8.8.8.8/808080818181868686878888888989898  8 Pin [$V=4 CCCbuf=C=FFFGlobal ě + ((VecDeque(head$($($MA Boxljk# $C+(2 $*,* "  [$V=4  `W\**D* \,#*$T* G*t**)ٴ۴ܴݴ޴ߴ}rÜĜŜƜǜȜ_w *D) lwaker local_wakerext_marker_marker28})  [$V=4m cxnF"+ $+,+#\+jD+$$+ +&T+ E++* +5 +D*$+H0.tAE^$,,,#\,,D,&,$T, A-t,-+,D,,04_$.,.#\.-D-&-$T. A.t..--D--04_t0<0 \$0L0040 \ID00&T0 "P0t00/ٴ۴ܴݴ޴ߴ}rÜĜŜƜǜȜ_w  /  [$V=4 $//  [$V=4  "X\\   1 t1<1$1L1R41 :D1$1 1(T1  E110 15!1"$0$0#1"d15F v%t2<2$2L2242 ;D22&T2  B2t221!2"$12#""&Q 't3<3$3L3343 ;D33&T3  B3t34 2!3"$33#""&Q )6 ٴÜĜŜƜǜȜ_w^f+6'5ٴ۴ܴݴ޴ߴ}r+6  [$V=4 $5 57. 77 \$77$8 |$8 M7#FT886 8(5+7-$6$6-c04.*.[9 ٴ+Z+9)8,8-$8 86: ٴ++:*9,9-$9 96< ٴ+H+<.;,;  [$V=4 $; ;j=3 == \$==$= |L= )=#F|=>< >/5+<3$<$<3c044*4[? ٴ+_+?0>,>3$> >6@ ٴ++@1?,?3$? ?6$B,B "  [$V=4 ]T\B Unique ]8"O 3f*ہ BDB \ &B$TB JBtBB6A ٴ۴ܴݴ޴ߴ}rÜĜŜƜǜȜ_w B8DAA  [$V=4:n:9| 8:x|H8:;C   $C,C8#\C  9::% DC:H$C  C&TC ECDB D 75 <C8DC$C=l:9C=\Z|:hQU8:@$E,E8#\E 9::%EDE:JE$TE AEtEE8D ;D8DDD=:9= : AEp86:C$F,F8#\F 9::%FDF:JF$TG AGtGG9E ;F8DEF=:9= : AEp86:F !,DerefMutD" l<$ٴ G Asynchronous sinksGD This crate contains the `Sink` trait which allows values to be sentc asynchronously.66| !STSGJ" IlHGٴ tTLI A `Sink` is a value into which other values can be sent, asynchronously.85 Basic examples of sinks include the sending side of:t - Channelsl - Sockets\ - PipesKH In addition to such "primitive" sinks, it's typical to layer additionalA> functionality, such as buffering, on top of an existing sink.NK Sending to a sink is "asynchronous" in the sense that the value may not beMJ sent in its entirety immediately. Instead, values are sent in a two-phaseMJ way: first by initiating a send, and then by polling for completion. ThisOL two-phase setup is analogous to buffered writing in synchronous code, where IF writes often succeed immediately, but internally are buffered and are *' *actually* written only upon flushing.  PM In addition, the `Sink` may be *full*, in which case it is not even possible ! to start the sending process.  LI As with `Future` and `Stream`, the `Sink` trait is built from a few core DA required methods, and a host of default methods for working in a FC higher-level way. The `Sink::send_all` combinator is of particular KH importance: you can use it to send an entire stream to a sink, which is 41 the simplest way to ultimately consume a stream./.sinks do nothing unless polled$   $ W*W/   W\X Z\T@= The type of value produced by the sink when an error occurs.,  [63 Attempts to prepare the `Sink` to receive a value.HE This method must be called and return `Poll::Ready(Ok(()))` prior to each call to `start_send`.JG This method returns `Poll::Ready` once the underlying sink is ready toJG receive data. If this method returns `Poll::Pending`, the current taskSP is registered to be notified (via `cx.waker().wake_by_ref()`) when `poll_ready` should be called again.A> In most cases, if the sink encounters an error, the sink will+( permanently be unable to receive items.T:;<  [$V=4 :W ;l8}<ٴ۴ܴݴ޴ߴ}rÜĜŜƜǜȜ_wXB   W$K52 Begin the process of sending a value to the sink.GD Each call to this function must be preceded by a successful call to63 `poll_ready` which returned `Poll::Ready(Ok(()))`.JG As the name suggests, this method only *begins* the process of sendingKH the item. If the sink employs buffering, the item isn't fully processedLI until the buffer is fully flushed. Since sinks are designed to work withHE asynchronous I/O, the process of actually writing out the data to anB? underlying object takes place asynchronously. **You *must* useFC `poll_flush` or `poll_close` in order to guarantee completion of a\ send**.IF Implementations of `poll_ready` and `start_send` will usually involveFC flushing behind the scenes in order to make room for new messages.KH It is only necessary to call `poll_flush` if you need to guarantee that=: *all* of the items placed into the `Sink` have been sent.A\+]T=  [$V=4 =W`B   W$$"[.+ Flush any remaining output from this sink.HE Returns `Poll::Ready(Ok(()))` when no buffered items remain. If thisIF value is returned then it is guaranteed that all previous values sent'$ via `start_send` have been flushed.  FC Returns `Poll::Pending` if there is more work left to do, in which WT case the current task is scheduled (via `cx.waker().wake_by_ref()`) to wake up when!(% `poll_flush` should be called again.!!A\"+]T">?@  [$V=4 >W ?l8}@`B  # W$"#([#A> Flush any remaining output and close this sink, if necessary.$$LI Returns `Poll::Ready(Ok(()))` when no buffered items remain and the sink$! has been successfully closed.%%Fm%Wm&(% `poll_close` should be called again.&&JG If this function encounters an error, the sink should be considered to'IF have failed permanently, and no more `Sink` methods should be called.T(ABC  [$V=4 AW Bl8}C`B  ( W$(((@8DD4($) T),)   (\^T),))^T)EFG  [$V=4 E Fl8}Gٴ۴ܴݴ޴ߴ}rÜĜŜƜǜȜ_w B ) 8$) *NT*H  [$V=4 H{B + 8$* +^T+IJK  [$V=4 I Jl8}K{B , 8$, -^T-LMN  [$V=4 L Ml8}N{B - 8$-.] .W$."D.,.  T.    ceikT/,/"/ZT/OPQ  [$V=4 O Pl8}Qٴ۴ܴݴ޴ߴ}rÜĜŜƜǜȜ_w B / 0JT0R  [$V=4 RB 0 1ZT1STU  [$V=4 S Tl8}UB 1 2ZT2VWX  [$V=4 V Wl8}XB 3 d44̌4D4Never,4!#G""!" "!"l"!""ٴ!" #!"#!"n !" !!",444&%% 4&'()*  *()',.T5,5$$+5YT5YZ[  [$V=4 Y Zl8}[ٴ۴ܴݴ޴ߴ}rÜĜŜƜǜȜ_w B$ 5$ ':C6GT6\  [$V=4 \B$ 6$ (lu8YT8]^_  [$V=4 ] ^l8}_B$ 8$ )&9YT9`ab  [$V=4 ` al8}bB$ 9$ *:3,, :-./01  ./10,.T;,;+++;YT;cde  [$V=4 c dl8}eٴ۴ܴݴ޴ߴ}rÜĜŜƜǜȜ_w B+ ;+ .?HYT>ghi  [$V=4 g hl8}iB+ >+ 0"+?YT?jkl  [$V=4 j kl8}lB+ ?+ 1@N34344@W$@ T@,@56789  9786 @\^TA,A22>x ??$ AB DD FFq: d'SY,ZO*^1p@3E:}@OJ*'v0ܗQ2OiG1_ !sNJ,~X.:n>bӑ krVqG+8xml_mz: R'J~AsrEᶍ3 "M"$SJ:=n&yҖl*nLW.uεct. ܲ YٸꌨF %w1  л@]j hVs`U+okr8hҸoNZEp}]c{@S[9֗3I-rhn|chk bIk#H;ۡmIʾo[- U-|Х*yLktUU&^{50UTh@z +"ߟ^s ?!%L_@.5v)1mÇ ru^vTcEʧHCʫ_kZ_"jMO0-[;Te7XyE\ؒs!wY-EzIDb9-YOP0VNڅ(k9[*g7[,Ij!CVг_&NjcoNc}k(0}(e{EreO) ]O@r YnWv={I, O%_g"we3vFcv1쎾gp=V@8v"EŬq @ܻ>)hH .phuv^d_ק`ԡDe\:y/: 0c(ĺZ&[ i7"Iy&qM"lfL̅H1++++$ F#,%>%E%L%O%U%\%+K ,x0W 5 8;@>?@AAFCCDEFFF5GMGHIJKKLM=NGOQPPQRPSaT$+F+;;AFKP      $>+9,.47:D>?AA^CCD F9GeGIIJKLMUN_OP&QRhSyT##%)%,%3%:%A%H%L%R%X%++F,s0R58; >?@aAnA{AAACCDEFFF$G1GHGH~IJKKKLM8NBOLPPPPQRJS[TlUrUyUUUUUUUUUUUUUUUUUUUUUV VVVV%V+V2V9V?VFVMVSVYV`VgVmVtV{VVVVVVVVVVVVVVVVVVVV&%0%7%>%E%O%U%:++5,.47y:$<1<@>?cApAAAFCCDFF&G5GMGHIJKKLM=NGOPPPQRPSaToUvU}UUUUUUUUUUUUUUUUUUUUVVVVV"V(V/V6V?@@kAxAA&CCDEF.GBGHfIqJ{KKKKM N+O5PsPPPQR.S?TPU?++:,J0)5h8[;;&<3?@@eArAACCDEF(G:GHZIeJoKKKKMNO)PSPPPPR"S3TDUZ095x8k;;Q<=>?@9AA*CCDEFFGHjIuJKKLM$N/O9PPQR2SCTTU.47:q<'>>?A_CCDfGIIJ LMVN`O'QRiSzT.47:t<*>>?AaCCEgGIIJ!LMWNaO)QRkS|T.47}:\<>>?AJCCDQGHIJ LMANKOQRTSeT4 ++.<;<mAzA0GKPPW 2Z eHjM !U  0X  cFhK !O#V 1Y dGiL !P#d0C58u;=>?@4CCDEHqI|JKM+N6O@PR<SMT^U+$8+;@FFKQP"3DUY`gnu|$+26=DKRY`gmsy !'-39?EKQW]ciou{+++++;<< <<@ADAHALAPAGG GGGKKKKKPPPPP+<TAGKP q: dZ`*h|hhhhhODHT w:}@Om4I,`@r Yn^>ܲ  ! ק`nIʾo5NZEp+Х*8q: d^s ?k(0YreO[1mÇCvFcc}(e{EZz +"ߟ>'SY,ZO*I-r/g7[,ISJ*'v0ܗH1v50<_@.5v)Bokr8h)(k9[Qz:H;ۡ3-[;:y/pUTh@=J~Aq @ܻ>i{WDtzIDbNsNJ, 3 "M"Q2Oi_"jMO0H ]O]$SJ@S[-U:V@8gnLW.uY!s!wY-EMĺZ&r}]c{,G1_ O%_gad_mchk1De\o)hH .jkrVqG+"Iy&qM"tεct.  ru^vTDWv={_֌wíNc}XcoW R'[- 6ml_m)\^1pl*v1쎾gd&^{;9-YOPOsrE"we3bn&yҖVs`'U+(cEʧHEꌨF" bIk#2: 0c(q@3E*R~X.: b v"EŬhCFphuvkhn|0j!CT^l ?@p=fVг_U %#ew1 $E\ؒL0VNڅPlfL̅u л@%8x[ i7sU-|75yTeJ9֗3.7XyK&NjVyLktU9:=ʫ_kZGҸo*!%LA'p 7mvjdS2 k_g]\"O$O Ao~-ZP-`~EEdm4J%FVQlqA=pCp5.*IVsEUH8u([JNz0wz#LBu4i@b;>!NSi/uuVSlg \>[<5*A-w^'p 7mY/root/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/futures-sink-0.3.34/src/lib.rsN/root/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/futures-sink-0.3.34Y/root/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/futures-sink-0.3.34/src/lib.rs Ό̽leRGGH  @?b!M9 LBONNPJ+Q"MEGL5/E;M#OOX F0`:L;OPQMGKNKPBF0P3MN,K\-F0`FQ&K\-ON`Ce-U/e-e-$3a/Q1a/a/,-d R1< d d :d R1A d d U&"-1 Y3 &"-1 &"-1 ƱS11rZ[i vx86_64-unknown-linux-gnu71G" &h futures_sink-578a9e470927087cq: d w  ''  !!"f:::"3fw:wwtw::t:t:t::t3tf5:jt:t:t: 3fw:t3rust-end-file