PK#Lb"_-aio_sf_streaming/__init__.pyWo6xp3Gau `ɂm 2ExE(Ѳ C">ߗGQ@OeJ%(Y!cg0 $[W"e8ܓʜ½^AV0Z*vV F%pZnJ*_CqAD$85Y4S\KsmϦtKp#\PO Xk3VGk h׊B2^w*v@m+ڱQ{;w_/d&SRvך4m쑂 tܛsЉ&1+c~gcW0+ZTT@-u8e)/)u)4L1*+"jIEI4w`%hBTY3,!MX 1Wo@4T! \.S W93Q| jE 6(`AaMpOZ274ٙRE#}=Ɲd <7 aBPeYQ64bTkGp'b^s>&z=ޑQp^pnkiV߳mJ(<ʑ .$ڈqWl;q_NG}[-kR{*gA}bz4+_jC)^M, 4WKq̀w<''q8lO۷&4Ã<^Kc5`%SiJZ;zir$LU߆S:DNRx=m7qT5%. g;e>{COOiWqㆦgP)* {\ >ZqmdZV`K3k슥>ND0|ބwz*PRux"?69F9`@֢ }\ts!xq3L0'U w7(.'H:4lS4rYXvv9h1ːAHV~eic9?-iRDWG۝qZ]?Ƚ6]tv%)$]C~<>5z>"21KFzFu Ķț, 2}) 5 hغ`/\=n?nw} |}d0,C\c#WHv>xdHX&;3B@GFЌZ4jR&f22{D|a"_Z펣F?PK#Lf%P[aio_sf_streaming/__version__.pySRR K-*SHIM,2\aA~ : : \\e@ %=%<"&MM.PK#L>ȳ2 aio_sf_streaming/connectors.pyU6+E^:(E 6`0fV"!I5ZKuc,WRbm6Ыf찄Z} 5BIaO9gV=i0,l0#Zi\o#дJxyOq,;nߏ7л2z\2ߡ xׁi5׼'r*єk*lw = 'iZ%7-Nb.қ5= 6ЌڵsR =q!)\}aԃ28vDwTh'v5פj8JwKS!wnwwOxL  JBso%\jM\dWlt.!glӰ4ʲG&u/Zc|W\Z6$k-\Y2w_`ۻk{\[#$pbl''ʱժ|<53IFƹ u]~|,7HEpB] a$uPEsսDLeOI 1Xrڒ,Il/h[W5j46{/\X)*3&i;GN"IG7Hl'i,5l(nJq\TJ RĦFF0qurߜ lj3ҖoDpAt9(<ܸ)o0Q.` մT͇%'gHA3hYސXsIz'֨Jak¶ }@.y)E<|c'Ii"R:.2vd]dliT.d>G 3\. ~y:_8,,tSPnoPK#Lo;cN 0aio_sf_streaming/core.pyZmo8_AX9rwr4mmIp([YԉR_~3Wr^>3C*Iѹ۪-Ĝb-K`R [q-XVpٍl6le u-QkRu*_̤r?3UwXv-ѺV[*Y2k]HUb.۪S#TF#)jvꈧעyC LZB7[K&vi6nY/n SdƐ\3cWȨhBU =;G >PAB|;9Nql h9/Y"gb7gVcݮNh9BpT`L%,P5Qb+ʆSvqjY=Bflݖl);si8ˀK`cVIcR`FچTFENL6^tKk^oeRsz͖˺6V Ts?@(ٴa͊:EuڑY~b"Xu10{Ed^ql\`J$ʉЌH8 ƺ02uCܷ9v2/pԦ7Qk,2Ֆ$lh[mVYAۚ{ AV  (xzP$lЂX-݂u5M$]rej9KxU2#^fkU&4[,d)b4quSZᎻ+ lY`ϚoNٯ/:k`NF?1R*0HqM~J ƳǼ;vf<[߄ E^ h |+ya|A3 KRw0+c-~rx i@UҢhLo?g1=;Ij~FgꐿdNe٨<*EDّpXB 7h!Qͬ/f{:ەj)`n) 2RR|ᖣN[RWi΃R GfJMŠˠ) 6+5_KX֢\sj+u?D.Ro.860:aH~zݭм7?wu[,)fVVIP5D:T}rqE/l[P;5$tYbpNU퇞+7u띞u~BplxK"8qj;=۴ ?=mH_f.bx'Dݪ 0~hѲȇjZӔ\[z+q{PE'Aԛ;_\ j 4IϖåBnhO~xh{`K&)UO$<膀؏ix'#]o s 9a/GPCS{qD-f|O WB?u\ؤBCHŃsdO9tݜ~~tiOH7:&ۛzvۧO#Qں ;k^;l]Ud!A!s$EC 3̞h,YU tQ)L UKhŁml]|s? bL<ݧG-q=f<]\g*Xt'F3;G-~\VZ%?vhjgm84~HsEchҽSg\ R=;yP̡;F,T<KvH a7HSNpAiWԐ5q 8svd.Ir~ kN oM.[A~6ORD^"7x0}xY#e_[B:Qf`aȣ F[Z8}uC$-896X]+11An3y -UlQ<yϼ x2>_+&a'嫹w\؈פx@3Qp| ޹y8v/pч@dKdž<;W̎-Uj'@#Fk)u]}XH;BPA^+u~ )*ZE}g=C:hlfwd|?Ԙ~͛r?QJP NMvHcF:D#UJwR `|6wl4׸A!txٛ w/g=9Ԗ`_Bvڲgݷ8`yqIHxku:Y~,_ #`(Fzikp!zƠ?q-+>:_PK#LA )aio_sf_streaming/mixins.pyZ[o~ׯ((VJeFP&J7[acrhMMqв3&hEgmC/lDRelA~-#Oy%VM!JE1+˫=Gi)6D &ǜ|dD({3.L_}hXIN螩3}o2\ddthgTJr7LT4y1.FP}3`MĆ*,Q^+4ƠnWJwf0KZ@/däLN$)9zj5Z2FnVyJvIaRQY9<|XXV8pZ/Lڢ'xMe2~a܎՘eUE'fxAʊ}iD@Ue9C% 9#,0[;"}vNG{`r]lw4~hSԹ'l6XuúWxY\B}M>N“Nr (M9ZYS,TIc9_c6ȭpڈ˯kGtsm7{t`!k߸8/ȇ\% DB2@K%N,O-_Gm@?4Iu BѬзY`F@QT>IM'=V\aa?X,>؇s;DwlP{ri5D6NǼ60U6-󼙝"w̯+M7_Eޯ }~TG55NۏqVQql4]ʟNϿ'y@e͏"gy_PKIKsLaio_sf_streaming/utils.pyePAN0p]9 N->QY&hTU;@{xfުě&R`bL:uC :1`fL4;폹F@1~扜~dH6 i)^Oia #q?F&(7EQ&IS"OL6x3ǨsԇcNsp+BmY1Ԁ, []%f֖E.O)ry+ PKoLtests/integration/__init__.pyPK#L!<tests/integration/test_basic.pyXn6}W΃䅣vn hEۢ} F6kIH*^#wH%_ŦzH,r.g\H{0X y$S. bBc(_1HR$4@ei g*ӍBVn2ГJY(h2‡R WsLHƶyTȗ!bxNK~M=EϵseYd!"?bGTJ҈nΗ%M0+ Qj:=ͱ=,_>UtLɠs2Y $ds$D|ZS~+x9\2E k, Xe22w Qp\NqK=H Prjb$V"/ DbDeh $\Uk2?xVg-_RiDVG4~ (3*VEyHs@`_xѩ"DqctXKj RKE41& Ƚ5X((cM3DFe:/|1+7uz31нs[b&rV iK3AT4-uNKIs_4.FZ;3`e2kF|9ƒ6J$`9frD[;o|DxZhɃ@oac!2ݚ%WfO )~Jg*O_RU9wSTfNFd'FLtlY[Zwok:k2L}~Žp8vg]{\)އ-iLWubX_Ng_ OL1;n\W$kȮ5IpTlQ{F^ZlɟmMqض6٭g;U A {r=xy=ޏzl=Wo mH[h:ץwg#,j&ġkM1(z\C^w%>G(:ߤ QU2oxK60{ݵ+g_޽`zY`l Q}2F sT=09#Nh+)d?\!K6f*磢C Bb'w]]]x>T;ۧ`oj@*ivX{XW74ۿ`߽Z lY~w.;I'':9S#F>-nPKoLtests/unit/__init__.pyPKoLL: 4tests/unit/test_basic_api.pyZo6_>rzۃYӻH*Jz7)ɶ&<&p8uvv6)'0Jh ^)fGWUÌ(I3p1 ZV(d<"t4C5FHQDa 9*$h3E״uEr/9-)NB̨vh/|eEiʐu˰£(JC*1rnAkpcrۇ#F H6!>[J\eBVG;noVjϛO->n>]?=r6˶IΪ0 e(A b1i6RQ`j=Cxs}ﰝ/"` 3FhM my+Aku$e5 ZJ9"`Vmh{8Sq" \2i(%8qH=җzO;tyek.] "Ʃ}K=ޢl >޽\V߳$8(mJ0C!ד0 !F ؁VIFGD3T5$|8RXm0 3,i)8,8=[ҳAVۗR01Y߹^^Oeuor#u.~zpi2;6wwxP!rd`q$v,Vb :`UZS n fuZ1_HZik0P"h?*aIa4Dw.f-H4H2A3n*#b|Wh$[qH$Eߡl S ;zjI5OT3_Qa,i9Ds(߈rq-lő[d!0CmX.k$Wϥ*β?@-X'hulKC7+dqBEq[ze UB5I`4}-(lbhHX_7lba;[WVbW*}lB|4O]UB1a3ޡQ_/=/ː0 #رL:bU6#Yq{]7n(2!pl()"+@HzUcyU($IcU0hBx=yB(>ND2@j)ky Jewk6R[l: 8Su{i;Zn߱bzmXN::*8:ӨvI͏.|䠫S)A QJvƓcM(sU5 zwGŠ ;@0KJ Y)dml=Kxh6!юkOMԝ٦u\*"x֡Q{=%OS߬j8\2k~!0Oڭ j3 )dd0d>ՖDdVE }W zor}Qed w\D0H慾V<:]4tVGOr}L݀ =>(%ǝaK+@ -ɗOoa }b a}  @)װoA$7˱ >U)L!'pHCTVsyǓ^b_w%4G5xKƾS}|1"xE=\P&pip.mbĺ﫫T pU/zx.ޚ XG=Ch"r1 mңCһϽo4a3 ͼ=Ls^vwF>\qWCT/4~QՉ ' g>ԥdu?i/ofz4x_4yr-_LB:K2Iu#Nc |HXzXTL"hzF'o`>5~,Ǜ&2<6"ϿM𹗱FO9֘EZ]O Z3P]̭Ҟ٠lʟ>dc7DID1#~H7t.cn^gq؅5<[PV "J pr K>{*R\5 X3ԵZ6.wQ~kElwEW/އeۍͮ!r@rt[릒=??3h @2NKf%]/_Ɯ+C9(7Y8UXX}_ rĿxp^Nf ֗0f68Sz64E(vhK9u۽*<~0c_ZKŢsp('8t=Ў~q1 ;VV9QwB/ȿA?Z_ ~V,̡l^5_wJ HFI>KfXSj߸~( Cn38[mc%yiTUm&vvlyz߹E3_4wY#|>/PK-|L~Xtests/unit/test_connectors.pyVKo@+V,h mܪT{"c{EK 6Ilխ5efymw4Ѡ" !I.8\ B!B4-ae%&9- /jshdjL΄f^6h2EZ2l _Rk!痴p`y j&n xo#J*9+p} J17.^*o}9,,gY= Ya&˭L9;uh3D,x҈3IIbfz879pII9]LŔ %@It_&9S YA#UN[;xU&Padc~L~(t9A<B%t-yvGP~#ƕ9-8:,c 2@3pD7TuKv2OEP"PrmLlLnT.w+s*DzW}"t^]F^]_56XZU˩FG&!6e8Eپ-–B,tVvDZM\e1~"M/6uӍQS UwǬEq0w=jH\U"7?&\z7JҰw|] _^b}sSov ͗$,8XhDXb5RIq0))鷊 )!#r_,,SpȭpD^{9:Va/&j_PK#LȑgB 8tests/unit/test_mixins.pyko8b)Ik Kr.l,p!0]%CE %R^2E!ə832a#Ngh |8<ܵ i:9l;4P?] +E %9^H22bk87 Jc@ͭ1w&: 'Zy 6[،Uh|N0#S9dxrc:Y{xSm$}%F/`{]3'jNºehbmIȃcH׷MhEBuNSnG>L۠X VkpZ-Ì)ygS1ЮP@:Xhob )%!F],Ǘ(NxpC^btfNS{'þM~>ΎO'31|ǾC,Yҋ,-Ђ'mFD|$Wb*1`jڠ6g(bwmMKmS1g&6#" X̫uE_ ]b4%/12W}鵆L4$}>w{]c;LL̠̰&'vJQ'WֳuM 7`Ji(4=¨عE)2Uw>75 St\*8, 荇9"2#=-9> lwt?0u]8%:|(UHBokN E~R=` f75 MI< h_ mɏjwrak0z{IaQtt2xa-dRey.Z[۔Yg7sb|8ׁ3tL Zw,k"Dakɥt8ʐp: qKo<'jCxsxmW%s/گ# HFI[ %nƏ+U̶t2wn]'U 3F"<ˆ) Ao$)؀h|/*SM_꾄TR' a͊- ,{I[E>b1$ @fedktJJ-X| IK^)+7\`YeoO'KlSA%K'ggNI꤯t2].Aq"D.˽V +5KXj I!I#dFc)Ǫu!CI(;7MVڮd\q|ڊ#o- ?z]t>u{>HM?4` l #opjl_;7 [;gk؄;Fsm5\[M8|'6 4AE'4 1yuC\*'sm$:/<|~V6Wwk.zaWmC#%e" Kk{ȃb~%ȣZ=D>l[ǰWyqȟ"?m[>I)xϊy3ءrrSQ &]Sz\HrĈM^9?? xæ?Thx%b m ŗ8"^Uā;7~pKb_ٖmi[E$OcL4pS/ ,iL' 㓳q_쎴xx_wT{u3R|TwJԛ? ;yx\[vTS9.}.Ox&,M$<&J'PDhP&M? :[Prjpkvwldl(SգQ#Fy;J;?'t+PKnLi tests/unit/test_utils.pyK bp5i)"n4ZWC&: ?>1hT!+ޖG4n ':aQEcYMAO!z%YqbGhVbNbEzi2':W!DέX0~Y[3>r3wᢽcð92M ,O+(0 [fw PKoLtests/utils/__init__.pyPK6VnL!,ӓtests/utils/async_itertools.pyU=0 )Xz&KiR9RoOҠJxm5wE9d)IcV_Д$IRF2ƸF&lՓbD$gdux3Ѱ?u`7 N⯜PK:oL=SS ^ tests/utils/fake_server.pyYo8u?HsdIw{ƺlm$hEH%o,ÝƊ8{~zˈ\;zrF#,q-gR$Dh[*Ih{%" H"nxD"'{I%GFx!<YLXO{R*膫U"Q.ˣE"5#ilLqw4aJňN&8>oxu&rEbPK5sSI#.zDHqJגyΌh~2)Et˔aiUv٢>(}a NA&1Z?,OJ񊴐,E ~ |P=O-FN.x WB* Jd"'" чم ?~$30o` &P>2K 4-!O C_d9-!, "5rp@b{b uMҙaZ+7k3g`#--dD 1ʼT5Um^>ۣ q5)V,%|RĤ,/ *(/Z1sTO$\cXSڈق|7()ANI"Eʦ LyJ<ܝ5T]A&svƠ!@(Д;sݒ[/r%dZ ꗋPt@8ԏo5Vq(/F(;i Z՛,uQsvBv00ug'h..hy`* DzpI"39j!X`P`HQ4XX Rb)D۾4sI1\oN/$8S"R ѽhصIY#LMzR/1!+ 8@|6Cg=k C7JaAhtyM3 =/hiJ9ẍ0qwz.A3 {p$-G][sTzq߆q'{}?D-P^KCPo{hfݐ-7loѤt lMH *zE_hY"fڹ]/,K< gnԷ:@\7fdطD&6D?2K& #YDarᙩtj8Ix|?C!8F%+ Bqx4A oS Kd8RTfU4]AD5n<.lց5tُ0h߆ޯt*eB <έծ%]VpX:+mTCPިm@hj,azmp9fۼ&xO~-4I g7㍏v}4:yt b*q径p7'%3*<,lFEAV` *v ":t:` [LJyAl Zrv4>ʅwPK4g[+o^ "mJCq*U2Cn7g.AyZSnָ?D`.l).tfǸPuO7O:%z:%C;9yhwM'y[gf9sN NδyF]d{vjYÏYU:AԮc!0>ǽikCfXz,?x>mԍy]ٱwFnG GmvE_?K>i/ JzV=Gcr${\f?GCAR  {oڥP7owjj{*\xiHPK)Lw]50aio_sf_streaming-0.3.0.dist-info/DESCRIPTION.rstXmo6_A HjnhfEڭC(~¦ͅ"5=$% Gǻ; i2Wg[Svs1\6bJ|}.b")ug4E,vn>eׅvJ IM(|sK~@3LrcEk_Tzwhڶx3'їJxry(eE.D[ۿkH{u[1.+er^d5Lem7Q \= ꛉ]6 !~ vRU{]- B'!WLuߧADl~ E~V楩TX%\Aʗ~>{^ϟE#$r'H%ycx<ǝpA)=Ayb.7R? 3I^ KҎן%)eʴ5-)J;xc'¥;ٴ_pK]JU.@{K5H ]Js~ekk~+'6 d6Uɖ%_tX,ۀ_ǣ["><#>{:t+B,v% q[-n\x Bx%\N:\ (^@5s>5{1ԸmG<J5YwH/E El-Ȱ{ӳ`YbYxۘ~ыM EC` IpjŹ<j y# nJ+'vqe:g9d! (J/8 ,O|1EU!rQz9 J,XTM>t,fRhs]H YIo#GzqVmWyVŰqj27ZBQJhŁHe+h&v@#\/"M)i c,=t:&d߮:`ԍvP56;::i_XPL2vG+kă҈#S&ᨴ7қc2r]Πn6 tKV, jGE-sx*ĴDht3ѫ ,R<$5#D,OCdwb@ߤgDփK_˙W~y7sߵpM{+B?uz4BhnV7wu1- 3,iW2Qh <mk P*RCHq+xcL%~A=~c MWmR-f.~O2s} S0ƠZqh#8wh2t{4:*M V.V 9DP+'956xôS* hP0R W!1\VOHaF<NC\2vp9?oha2~r2<vrfٵ=ٌ,샵άl8XvkPv[zO 8!ni:vu&݄#ˀ* 8{EH(OvhsIY>Li1=%o<WoHHHJq"nqّZ Fb3A:\[/^.2?t˴}{1L20;ysq]zMѤdՈhB/Y:w톪iR>m`߿l=#)tkؓBRΎ_ b@}umSI8l2y$|0 I4&q]3?{rcK̇)Hh:/PK)LyM\.aio_sf_streaming-0.3.0.dist-info/top_level.txtK̏/N/.)JMK*I-.)PK)L3?\\&aio_sf_streaming-0.3.0.dist-info/WHEEL HM K-*ϳR03rOK-J,/RHJ,./Q0363 /, (-JLR()*M ILR(4KM̫PK)LfL)aio_sf_streaming-0.3.0.dist-info/METADATAXmo6_A ǹ݋sg4I8wCQx˚u$gHIU/%>3RL:El<1ϓ fLZƙe]E v]eR3%g+WweDrfD&R?vwٲq%lM&qw\m'i:n̒Lika*a]\73%t誁yf®FZ`?79KY/ݢbQr&,c#iDeaч[a3#k2?֕?kO'^iI XIaZٟՍ] *Vn4^+n-ka ]յK3"oR(]09K,fo@᥷= "Aš%nt.9zsZIF8a쮐zaPG㰘7N' ue!`=v #^8/{6^!Z<~o gzdHK_badվ˝_% %M|.1D^jG f.A+ȼJp$BPm)R7W4l^~JBnB;&0YTiN_{]:k6 ˨R8prkt*[\p0.>Po(GM $RʻZ۶|]/2bJn=j7%ZU.2'|\l*g~w~w1ًEއɊϤnRo3; Knı4,Z #ccT;IF\WwV~ Q*uB:DX Q`;B g_# -c&f$|<=ĝE{{ D Qm+/壬leD 3I%S;M"~TTģ/Xޘv}`r'Դ@I[׾=nzzoyboğ_Yc:ݥ;~Qnrέ;iPK)L4iO'aio_sf_streaming-0.3.0.dist-info/RECORDɲH}G̺ @D/c&<}q*w[OjX$ yZWM-IBI$À:h rYz",P>%H=T61lpQ)wn1OPtX֎N5Iep͖ѩ&\>ug28WAȳ2 aio_sf_streaming/connectors.pyPK#Lo;cN 0 aio_sf_streaming/core.pyPK#LA )aio_sf_streaming/mixins.pyPKIKsL"aio_sf_streaming/utils.pyPKoL#tests/integration/__init__.pyPK#L!<$tests/integration/test_basic.pyPKoLI)tests/unit/__init__.pyPKoLL: 4)tests/unit/test_basic_api.pyPK-|L~X3tests/unit/test_connectors.pyPK#LȑgB 8C7tests/unit/test_mixins.pyPKnLi @tests/unit/test_utils.pyPKoLAtests/utils/__init__.pyPK6VnL!,ӓAtests/utils/async_itertools.pyPK^nL]Btests/utils/async_tools.pyPK:oL=SS ^ Ctests/utils/fake_server.pyPK)Lw]50Maio_sf_streaming-0.3.0.dist-info/DESCRIPTION.rstPK)LKs .Taio_sf_streaming-0.3.0.dist-info/metadata.jsonPK)LyM\.ZWaio_sf_streaming-0.3.0.dist-info/top_level.txtPK)L3?\\&Waio_sf_streaming-0.3.0.dist-info/WHEELPK)LfL)_Xaio_sf_streaming-0.3.0.dist-info/METADATAPK)L4iO'`aio_sf_streaming-0.3.0.dist-info/RECORDPKd