PKѥ.R:2ر3streamz/__init__.pye=0 w?*3Bꖈ6ۓ!=[v;C$I)],ѷIH6Z l35@=L(g5FP`hSc^Wjbjy&ݭ{\J?~!z yL z.6.PKّQTP streamz/batch.pyVo6~_q,l}2ð!XV -l6bw;Rd"ؐ(ޏ>?2Ja Xޢhޮt]6{cףAQJ,p> _h΀ 0Ӏ;%wY0s'fZŖ7;͘!ځpC8Yp9G-CA@]q|Tآ(l3ź0 E 33JnGKVBkD7·"X-J.ؘj't͸LC͌ vihq h0x7\apss+ֳ`e#oK6'kx{/wyCWˢ]Qʈڽ:kl,,sY \n4ca4t _gN'4mZPe1ImJ;ܗY6ᶽ۩A{CBTUJx,i./g):@חG~:9'nфbs1M 't0R'0dH{dj+KCs=.sE̶ԋe~;+&OlkX|P {]}?aW*ڑ<&g7F|Z7n #Ee W1G8'i'dޔI84wzh8tBxFt ᡫMjXߥX'a?}8P:>pu\Z$D<5ܾz isJSb76AuLx#³$f6HGB-%)KZ2*B,lo5d5d,<-Sq?7?ь,N܇ny,F>Ypڙ!|r6 o bP GBZ%M-`NNyivs!u9^/헫CPK&,R'b#streamz/collection.pyZQ6 ~ϯb+З`9솶 k`(hulW{IlKvk &O$EԧDz%Tbͳ:Lf;QTbLjl f&Z? bIYTeJUl6KَiT(x`Wۈ%PЭ($4Ȇ큰Y$)vDF4#EJfyH`0K (* P̘=c>~xn?FLXeT1?m!!,`a[Y%WDGAg=ST)$LF !|po\3Ù]\G-R|CmI!ZeX&ِVd^#-4?2N<qtChh6b0FV&wk2X2_xٛ374eaa,sb֕YdvM7 QkGX,47>TkM`q:e)0?/ԓ:n^4K6)Q%gԕ?{/,ws35rV1T%rl+weE߻R@+olQuwͶfIB72Iɲ]ط Z_|bPN [QԠ. A>Mg-e,"y5Hg[xBLGb| $p*C;xj׺Cnj3 G JTljIa1F\(C&.2q*Ҟ^T44d*18_creB ^fT"g*bGK0w*y&qD%26,k-6ВsVܶU@4K$yCYJ"#HX&T7~ Mo)bp?|t?/45ABEJ]!Ir{Z8B,f d n˶Մ`'\qr{$oaޙme%a3Xs#!!pMP%IǢI.,| }FP`V篌E X&Нg(}frv%@ޜ$ |^;Om^dmzVsr#WbX͖Lyy5~ AK4,\3;$n[9/pVjf21^ɅmƖm x{DΨ C'qЮcVm_V^Ի8};ice6GMGNԷ Rg6t}3U"J+Feϋ9ۭd˿1śxh_(qU6Ezv]#ݵ{+ R rw7?^CM9MDp?KSun3*6vkѓoG/®gBW6Qw3g($蹮.P.cgI2~*E*+u" ƈS׉L98]|Z@Y>ԝ}.)WQT[{~v/ںu.XZf~vo0_R' <8x֖`bO z_xnϸ:7%ģ5x܍CR*X-s4GecwvS0Ni\N'e~4ȃT7%zE$Dv?0)wwGe2h6=Wue{cZ}KWީ%Bn^m[_B'rֿ ub1ͯ^^{]^gPK&,R~ٶv=7,streamz/core.py}sƵ+0tH:,IڪezhHE Dy{|R 'H`gϞ={^{v^WhWeʬ2yUTJzKe43௓^D0'l3V:k"(*($Jj(/O>Ӽi| 4Ƴ"VOtf5Ω(DOY;S&,o\-4I@?2ړPx:z''E,1/K 6@0ݴ*`KJjx'D gL8H 5<x4rZ7#g6G+~:P g DVpfY-)*56 YN&:3HX~>~"lA68e' Yx4nh2-1Zn(FzuК7&5+0uV$[V%}STH'x˴?"Wg($7D U6uNOOgUz &4zsX U\fuE[Tw2)E}QRgUd벵fnٺHjlIV*+2?"Hdjh Qk5 (kZ|oĜ>]P6yz?$5,JhWSۙGy BR\"èZ!K "HDW@Tix rJT2kKn80!T,:sphbq;E}-{AA;h"ELjd|(6:B Kb&:,90nF#̦' :X^I^ х ,1rD*ej=4OGQiB_dIuOX\Y )]U\RZ5,s5x +򢈒4lـ|WK$Ҭ#j:}[h(fU//O/0$5΁U,c Ϋ^k1Vy~֝Z&Ii4'H^hM+  Mp-YO ։^E  D00VX xC^:p<8cp΋ռ4SGb :pB)4H_Xp v-} @3~4 $0A1k=Y-LA ^T!Nõd3v& zXmuUXXbRѴUkz%ʩA9;9&}"THhYa19kaS2 `p G/ɪ2V@e?o}~sÏU&gdR'$as@ }؀Ƈ0b ގWZx} TI6*8uZp>?}e{6Xu}ڃ`S(UPʃv=C2~`4A-?EjP"-.y0-B'M(0VtKkTXoW7U40%A;0>"MLl]vVÄXc=ur BO{yX1WGh4NqO}!)Y38fObs{I w|͑<f++L3aPDaJ^q["ִe[CQVZu*--%!mDK E7Y66y]"U9?5:y lΖ1?z <%@˒IOr @#8iV!A`Wu?J,I2-KXdF61?eF7kpo+4/qx>+~ %DkN!` ajJH=0f]FS̯u}bv ؜8&: SI+ <,oLb?P&Xw؁7 "ZorVJvR|c*l,=#=pᒣ. X "Hh|9fizԐ *,=o T bTfj`r5ɴZjGѽhv] c?T*Bq|N~Vmvk]W}px> 4ٱȮ\w߇טqz,&9k.$ ;> Gx:V?fs6{JF@3sE&mo!73] ꖀ<`@Jk+6ioS!=&,-jpȺ07 4bn(a Bl|ϢxFVp"3418m`4fƃm @l 8WTc AS/QoA Ͽd`9 7@k|A>5"֥U13qoBTS.'k%J2{21ڌJ˥{Oѻvlx|\j[?*& z֣G+}L!my"i7='m#4^Kaԓhzvdkc pbLƛ1׀f`EV#&jUި7OJ|NI% %6XϧOGu _F6f2_dr-̟;$ 0"8Vڙ[3wCwy 䡂_u|xVYL/֣EV*]?7/GcLP0yx뢎5LV]qbE@{}C3怲sTCQqy_8h?oR7E!aD\/`0Rқ;u =bIq\8]/?5zb\v |ҧGo/]Ť{~h ,'#%4IKZbc~߄@2NAQmeBjv9𸙝8k)MVCI O 4=bayQ5%0j74 &yg\hک$LWx#:GEY([l*BN%)^Fn$! hD|K^ʖ|!;ZGlWLURtZ%- S+jNtl<,6Q'cLܰАxeP߾ѹ'SL%lZ.StTMje 29ް(MB G;Yf+[ǐ. w4VChG!iǣ+  ?dDGt NW3;Ɔ$gq.jW;I0(d<sÝP>2̌txF#M5Ѐ=W<OfF}\߰ዽƚIDB#Tʌ5:WA|2^U~xs .j/+z QNϙb{( 4HAX7%Љ&ryc4d-fLp0a7n}z$kK~ JluDWtB$vyz 84~4/(P~ eD0 Xͣ!juܢmcCªqf|Ky3ږC6_*^aqU ^/u1Q.X"ȇ2M?>À!8Gc"?i>9HA6'{81 9~Vpm͋tӯGm^cUE8ܩߘhK@b:4v 2 0 k-)UVc\y벤Hu$ot͹FӒX*wV-J0鋌$pD7d0 7tWu<NyFV h[ٺ/Dx9LNߗʨ41$ )jnRN*(R%M򶚑w(&sYMqP!cU'Ll VRFfkN_جb$Y4}$ҸQ&lHVURJti66י*d 9K:Q%?S˜(n,pzPGQ{4;C?eg3يpA>5 JH\!Ut꾉Wr0yt ƇY|0D`9C]8h4S^÷kf01ZD]r;D1Oc;uG6i {c7e$r?%%4+ (bT[OLfM%e? {#Xdzl{JCoO@G0[9  NدgrOpX l{*!0F^H^w-a> DLGXS3"Yˇu(؇9%)ir~ (dg$&bvF[9Hp&bqs$Qu{8mE*Hh@WmۡH?!M_Wj+ \yfUнr r92?Ʉ~c֥i}a9omVcLUfLmOj<rDuyt0NlE2$rA\|W _K~A&Pq`мjeL1Sǭˑ1U*"9^?}7{hK?W5o #=[j0`]LM\/ux`TռЍf)ɀo1ЁiYXCT'3ctW]5 )M7B6vtě!Zj˘VfK<)BEN& ven CH\©ID2!ï*r1: ʬɋٓCˢ^Uϒx/C&X; eAKX1ڮ4Y} Mx]\w=F y`9z 53_W(ғ`T =4(*zCVdZyBԆ{>6deMae+ӏDo^ቴ9SU=X>?}PCfKf M> o;'n6,+$zIqWsqڡ]jLviF{#mpBh!BC )9;U),$vb6^8W{Ԗ.:H@<M_n>=qGqSaJ}ŅvFfs\KFIQ Օ|liAХuw,f.dz@il06V ~3BD##M7yݭy\O8# UAc~н.kTwyVwOetBsV1@cwamqܡT >-:i8s) H@3_(ldRDE hE?IݛMɡX,nL, @ޛWٜCg" 6R> 0B࿿g3p&cl҆e63*_ȤݑZ0h㛿3ꡈ+_N㝅K) [-`u-wB j.Kvz?P1A[hNO>r(a[/j%C);V[v eMҬhQLc(pB34niT8e?:gD8TH5g|:(:EuFeAD'dy"6wfS7xn6xO=tL|ߊ>M*28Kh!D찷^'ɮvQ" sd &M8hA~r sj Px$&&3B[D@J¹y3d0o]:ktpC|n6F7oN{t|JM0^\3 hb~nSq d/a$/@Pyx,ЦyH;/*8 2 PiN! 2k4ibI}z zc'j,41Xӄ{^4g}Swp}ns9:I{%P%=)$z_q`n(95isJڂ^)O`:": H +rH铦heCTWl.ܻC͘-8 ad]DFK&l.,L#g Ϣ>p,G2tOKLnŋM .1<6.rD^c}$.sojP$3>#8uDBLLtD4QG7tv=R/Jvzj{Uc15@ɦ_A= f,>ϪKOp 0g.؏N*w 4t}k(y_Q_PaU$3VFXeehʕH0%%h3>!j2S[,GׂwE ="n`;{/Y[?ϫ.S dbc&nO[ɦm&refX'N1chvvd:WQ]KSYz2t/)\io7sv &ss02Du728.ӬF?UPJ']_H3{ j bD徦dHwDՕ Z$.\؋g (oٿlDP*Ypf UAA윰Px8׶n Nz8pFcV48p \6~@s%˷EBP7BԑZo -W$-_]^]hm!r]6m}Ƞ7Q}yuUh.٬p=Rʲġk$8؆vГդqK/lM} )Э`»\y8@ax,c6UhwؓBO]B0DGvt)!'^f lCYY"B_%C/imݦ|$Gtl[R7.{ɊT 2h(=[1_/KZVdxdtJ#{jD*;Q㨢r67DXN0(qfˁi8('X\m~WGAs +yCZlC$,% cg_U dSQmu ދ&kGېi@hCؐm? ϱT݃E,pSKƤ;Ů [I_p/ y6'^@i8wI4R3Zh'eZdhOsC3(;9@YeQd|F@mr4My4X3В?UI27뢡Z/']ivoKnv[Q"#6ƔUy|Ml:5EۭnFӍקtIpCكC*sHL߱`.h2},@qfӝycH_w*M |evN&iC ȷyFZҝs!4UTsՓ;~+(ܐ'vjUVK2hAs3dNmmU偖<oooӶ=Ke0J ;NDnejl%56f),bx8hܶ8'6 uUDBkڪ}b? 2;}ɡ~+l`=MP;$Q`[nT+D,M#4n1q NBsev[B@>u`/`{c|-b?ځK4`HK*ft Ѻ)[]/%l95.C- ^)3z aYM*JPwbǽ7Ҝ-~ v}1 .80y<'X[>^gzLuFD&If@j(o~34(Nv*Y*xe)P&;cEEr$tUCaT090#x`R&7Le/uߣ[d]FgxK 0'O#j*_}E4߱B Nmw0M 9+ݹbi`7 /Eֿ\ervilzլQ[\>4lUsT4e"z{9EC'}{ < =V5C0DKB#Zw(q*=.=}"hʣ~_[4͇;y&h~hZYpN>RY?pQN&k3utܠhe^1vQ#.c6njMa86k7: Еln9c*fPM\ᮀweVq,FE%,4VMwbx rӱxQF6yVN^Ğ[g d173p6H~v=$@X%ed:B0jFq@ Ao .-(NMm 00%6"yuG%{Ӎ\X_G C!ggdSW͑Ȓ_eJ.llaO'EXNӇp|N8ۓ!cg56΍oΣ]xOdrkҡNϯjҳ=v Y4XڶZa? T5x^]/c6~<'95ØUla4oใw ӂ?/,wQ:봡!TˌY&~stoAu,uyI\ajLy@$͊ƑRsKbɍ؆4WHhލs so[ǺyhPW*" Ìfl@mAm0Ό^]5jpxz^=^Y1cl.Z>Ayvo׮(?Ҭ,NӢ>^&H ݷ/W޼x$JVvZU-&YŔyn.%ssPnNʸIzG_k9y꯯tb E+:;F|FpA3Tbypk nݗz amD:t 3lb*zbp9{0R^#n~%{B X\YQhXQw۟VEA9lFy vU.kکݗb0WRͻmYB)(8@6Fl8'*KRR4C!~"ZHZKۛP0ǐG \0[JORfC3vuiJLlȵen-Mс_+P%g~PS mpύ" Gg;|=LqYv܎3Yhľ8Ca5P]s50^6V77c݇ $眒S`lF˻^at6AZ>~v9%]rqQp @j )0`o{ի5y9Uy 1r|"쯘:y+N2[c-`¶'xUIZh/:!CggHe]xk:0VH#0F8` *r<!:'kƬAD=n<31б :ZΩ}gyBQ.2yC:Hup) J0%*amn\h,#="OOY#GW#U@4pKhDKJnd8%x 6x7rjIM.rii50"kH.a$7U e4l! + ۃ ͸0n h7}zgzw#([| WN jJ(" DDX%G 4]$ >`t-fqތiIF o@'Pw꨼ғPKّQ.dstreamz/dask.pyXM6WC@Ѧ-K[t2-R Rk;3$%QwޤX g3Xm2&Z7ѲNUF(Tn}6+ Apn Xa R(^AM+Ms]܊{Z0kHs)@Nf~4`"^ƵmWA BŒnl6%7x[\...[o q2nܜz_u{FI୰f7V+ٙVn*zZqς%Fv]0)n 5"qU8Պy[[aӮ+(a n kZŴrv2wQ= "ⳃ eRQ57PD(,PޮV ,IdtSqks VlÕنnTPy0}A7~859"8Z s^V~qu?k6}.1}d{ݰ0>_0!rSCR/${)&Μc)3_ Eg1i`oS7Ix%l 2aysc햞B|e:ZзM ikgi|&nJh2^ ?(N∹mßz|OI ?A$m]fz.aۍ^Prqgt C?kG<> 潟n=̀ 3΢zAccHb3IvT[h5EgBg7|iw'LP#EL7&Nc:Y7|&gQOpDRD?:v%ޔtjpĝ/YYJfag *FPKّQH nstreamz/graph.pyYm۸_A(8XNJ^օ I.]IzjiD=wfHJ5kgy!$;۝lV 6J6IL6Z,7s&Viڨ"wsV[ijղ'N*U J^M2IdR ˋJ&Φojnjl1aN5R1GEnc-R4q +}?aXnw5]-,"9wh-%g)³jVDi({ VejF`oqXT)J5iD1r۠ø#b!x80iZ)7dտSz,I-2ӭS)if5i>6۹Zq"I,L @swU76Ň93E"ܺhJ*Āg`n>kF׋Ć7/v'W}S P ЊGjrH(̶#ͭȃmbO %bOD3PɒF11GG/'=iG0^GiCd0zDʬkq7#٠3nKKocjPVTxY_c<4UGCC^%7X!^fJܹi3$@{J~썤22uD^>e/]=hep2~GNtك-ϢCl <(s@3#D?V|-e\q k6&3;ފe9 FDJK쒤Dܱh{DȘi]сxlY{K0QnGBt161O@BgrU-`lj@"D3bea/-gc2qR.A@Y}(Eg%PGt>#@n!\f_EaYnnbISD IO7USQ>vE !jtҮj9j޶ f_%:$jO+o"D,HԷ7sv~2V&pH!HBv##VWْ͇K.YieŜmUoX'b7 GH̑\DHp`khz.k=;wUj^Y-0Q-JUrf'x?t&mgXCt,kglXO@|a"끗pOkQp< L}w5@:!@2<rQ#ժ ^;{o-2j,̥q^}m-?9"l(G0q(qU7RJ|^rC`oMBS݅+t;(٭͛ p,4BD"*U8+2\V/Wa堘 Kn9 O(+D]p A \Z+=>+` pКNVhs=72`KTkp5:"N{-]NZgH_m-x[gVw]}9o8^ )J4@έJp MC:3 GCi|l㛩XVY]U= \&]CECM:bدF&BRF#ջ>gıVxmU :7?x < w  XC hTv=җi{#>jy=vǵ.fyo,8:;pQ{W$$ RdGC͉:z [뒳Z$>DJW/`?~$bJ'5VcH jΦsNGX *T93LCpVquVcM>_ eɯk8gi"u$kĂ]>n Ĩ&YBnZPvBEī׏MM;LA%c\v:a߱PK`P;DZstreamz/orderedweakset.pyRn0 +bna:`a0nȒ'l'qu}S>nz |P{ 'qayH 7ՙt a lVoWk,( =2 ږmO;gǰGP]@z^1m8$]J(;E84gi1(7RβL܏nd_:JcdJ[MU4yI/uX`ӤOZR^t=!l6T=R-^~pAYwts ڞܝER/pCG Y<3Rجubxt,p]cz&6)I\Q O:j 6)qyI @EPKQ@xstreamz/plugins.pyQn0 EZE9D$Ѡd+NmE[pݑ'#K@aUE30N0$=f2h![ ]<L!ѳ!K(\5?Jquv ݆tkc&|aYeo{hR~!6>6*h`Ϧ>B =;G8)ؠZycmcmDzl 6gw/N{L'6ҿ)PKّQ/)l+ streamz/sinks.pyVmkF_1>:~ 84 qpp=4bwe')]%NQbkg癙g,N.`N64D(Πh$`AT=6- a8jYv;a/K*wJ -Xt:IR k :I|gD?E >ʾyTXCVR4FhbQ? ~y_⇭^sU \*y){{s#b ȡ `\`]M%[YO6J#;q0F*0 34 V_@@AZ*̓G^*2$]+ JBv+qDgF#ѡLP߰Tp>-8P)WLW9׼q(1p0Q2/X5 k^jiv4~ҌyJgrݻYET>,ZfJVfU]+%k+]2s%J_^/9Se'uG|xIb:іLTZRa&2 ߥcvHᧉuPK[Q+j'kjstreamz/sources.py=k۸WUek8DxƷg|YL EY^~ #Sm<4~ě<+*4em*"|R?UFr*+ Ls6[ry0+nuU2LDwqZ.H&\^d5~=99Rqz;2NFND &lMDg#x,%=—eRً )xz"pLdL- P+~[ĕ*R]uw&o:qf "@0 R\euJzUmSXfD)a͖%}U)&DTDVe|q;Q8 d KjN;gI+s( z9A< @uT;V"ɲg.|kE%_KF7IumdLvx!](AʼnxӠ;!dkJ]a^QՋDfatp8Ū [뢖ͻ:7 Hu!q6Gzΰ &4ͥLcK.%BHf=uaPp ,6BvCdUJ9zQs(da(H81o;$$"M݄9}˥ +"d2f*m0 VA*hDB28 gcv*Noc,бpg~2I(#/'Az{4.@w- xEY-6j] |g` 5qQ @kd8Jq 0&[Fa4PJGDq 笒8ȯ:߽ӄaoA‹g|Κ(CYB"t bg&|?DkYagjJ@ .LdߵL`TGd>F6 +% 4Eot`O2&e Xr,Jq&5,E˻wG2NAB[vJ蒷>a[N9` UpP9}N$b_`S0g(0|G葑I~sX}6e&7|7(G e5Hxt+imǥ* x@0S?"b MފiqÒB5r_ Uaoc6|` Ib2n%B]x}ۚ!"eO6Di 8Ig`,vk73&fL; D\@NO1T̽ݶ~te"!7`5LLr#hLdP(0WlOt-[ 8 ٧ <#D΀G، ay7jχ Qu@+$?U+ 3=ݏK㮈5\nj鞥{hf$ ?lԣD[zʘ!ePdt8 ;Z^ ޘ|.1x%ʜ}+T[s3N!֋B ) 4p/@m8cwTZR7!; %3Aa pX>Lld$800S0;ldq@H dD1 ȫ"60GZ'm+-$ZLSwLfҁ1ZXj_lE]EbHTKSbQYEY)m,ğ3%hHE1$ U-Nbl_[kg8==f-a~aag4t$xr#mm{"ff0L1yA¤k3 趞֫8MG7;Oi bVvZG= k] ")L'"9my {Zޞ p8vٺF|VaiG~1lC2ҼnȮ*ct7z}})._]]VřUmJdi*9MeVC&"x*}Ԡʾ48ͫ]2q}(|?"q;.iEqoƉڂ!ċ.ޔ5F)Ӥ)i&p&wN'-Ud B>77Ƌ&>׀l7dȌ%opf3=ؠQB /`<1!!+Y;w _{E:B\br)VcxQQRE\3zh4\-y7&.l[2mj2,6Jko\ l 6 |u5أaJ:y:k2YJlSQ@gVt/͆T0mOqU:jЖf[.0ahUʍ횃5'F5j:; l ,}I\]?{52tfld~yf %_V #`X+M'F :d!g8N3z,3f[6R=M#eu"w~4ތga p7fkž-]dݽ*MP'8㖵.EwKm3wFyz/1+QЋ">x'ޤ˾TV>& QYUw]Cz\HbU`f0vn vpj^_X/k:nmzZcmƬ0ޔTez2(ˋ"(vN@eiYX`$q E7~\Bb{W=sTB9F3 } r[BNO 8eX 傳4c=DXTSѦ~h%ѾƁ/ۉ8nr60-IGTktoݯ=s_j y\/*F2,fhՁN, i&yBOꛤY^WkD6{&AeqdǢlbvV9^V,`YT~5C6 =.6\I(\ϭv=>?Ǻ["ToīȏA]e X+JLऄ@l\Wg@!L,}?zKȖaa5R}}#¤,tZ5Nڗp_Y on.@aqygܝ5/4$n. lMEw8(jB/uv9z?q q_0cj=y+wo/h7GIe<&bN1O[||)0}N @:[=2S5ώ\ߜ欺.fxM rS΢4R O p{vam5ŴseJpYĜ˅w=5ă%uV3L~n`8LDyZh^iwt(ҀO<,RSu95D_J9W}=8e(M21t&tŏ{&+r I?s$A?.M7KvZڟ/kxta/(П&Ive?9{ yZhAc-bS`{-=pr@i?RKOPl0T͗dۉXǫuO^ b@8Jxv5jXt{Aπ~'3:Nn/33ifuqO_ZݮQmF33^zG^%6{{?gs_ǃ i3Dޅ4 4Q+);w29v b$")tUG(@nƩQ3qZIOώ~\'mNJGʏQO]#ԡ4#tm[ϠXso8LZ+ S{A5/+$Z4EJ:PW7|Ias29|P$iaR%YؾwxSo,lKrxI 64}7P$D=nkLѰ#d4Ų xnQZB\"TGc !WK#W~e"Ʉn`9@J+oI ~zٕ*պkȱNR@Wa:d`VQ[ĈBR^ֺlW]`t Z*2y Щ=e΁u ^ >M>OW-8'j~ d i[6¬w? h۸Foto8Vjl^RsfÔ!uIKJ c0\خ;'  Z.:N_KꍞJ)7UYJC'O*eTZ&4N5]{`kKt\I'jb] (FyQ8s4s1tycҰ4t dZ|P`s{i3n[{MnnvOjV([G*wAQ !B'{d}lCIj}f/!7{)Ћ&u‰/xoH5<Јgf@+ő#YeMZtQ}4z tcu~uT@N&7<\26*n\퇛zlogp=W-7^3jfcV&hm\2X-5c=׏qBYnX)qP"_>MD;(ɡd1ސN eaPP#'< v>(Rbb$}r6f]Evq#ά ]k <J:xȎǻuM8ƾK$~wm6^uT%}uB*tú@g,U1L褈B &JI몬(Ŏ`PKّQ streamz/utils_test.pyVK8W ՛F,e!vف!sB0#KFgz$K~tSvU_U}rktOjD6.IzxRwP]z6=Yqʏ C+$D)>+"YlQɼ3CR=[MXMS ]yK{ _EiS^-q1QbPVhUvۂ/HIvlG>&3b(#W¼/ű2c'񈶬g@&O"(^&2z#·b#aa޲@fzDk=AZXpu-TRGi6#V’ 5W;G }pM3rbw}7i*̀"'ͤnXN~# 1U(Dsq{M%u\@z4Tapb!c= {oDP\ʅ^ƈ~PQ-1%#h؂'=ң+o'gmPA1VX8Wt-1aYNm TUp2;G9Lpm3 !ư(b37w Č 9쬱g˓窗S]]ƿ }ကw~``H$#N<"#[u YH刷c=_`1U&gsp+w=EHH6⩌f^%3cT+F8G=gc[b[+d9Yt $q|^ڣiۀ]K"8qk84 = Ku-] zhPKّQ#Eystreamz/dataframe/__init__.pyK+UK/JU-/*QpI,It+JMQ3uB0npjQ&2d5o߅+_U|pqO/xjZ},A\0W0f'Mszt֙c7۪ 'F]F6,W}ͨ5\| ^&Z##tc#ĐBqFh*+ /^KH488nmR˜ U>==si,CQ`[ޮGv:%QgZ_1B $|Ҵʮ^1 UвDI<¿KgH%%_GuuvF.8#8Fj1F#>#Rƃ 彵l oBʞ?eO$<_,PPY+O5c$*v@ &k-L׻*uADgw%f\4=e[pB:)e`k;UU^ QܖH3;̔`->tw|Gյa"kZ_lBGE%ضJ3!EڣW*/Z'e!ZLR*e;z'E8hvyH&Vj*m;Zݐ?A[l{ ށXrzQo :*b=YFy#i##wBULh9,hi9%(bZC]TzDNHDcUŞ>BW,x&Y`L2c WXRVt"k^b2LSm誙 |^u+c|uն0f&ڮL#9zW CS9G"*:Ԑ-N#  7vsmv^vs̨@% L6yP5FTIZA&,13FQDr Y95 cV!YH*z_a"Ȉ!2:˩Apf3lë 5G_U].KIEO.!yyu`nW< '?%B! H@IvDezI6qTy& )dE(2hg{} B<'`DuSj` Rfd{j h睲utWge@y2(+vC=DCAs mp3t?Zc#\cL <~ %~oru:aE ǫb|`ln"'(f}wGzKۖ~hu㭗"?J"ȝ:˄ ev{nuϨ7:\~SVZ<+5#sJmhǕ{Hwsgyb 8RjI`JXNҏ]")#άL:o:DRvӫ 5V%_}m|1]|O] w&I;dcOp ggEx߭=vcpCUXEbf@l-pNm՜N>qQ.(L!Gd9OMcnq'\ ڥЋX(}=bux [UnsʊLT]jcs jBu:_-xZ-qzjv \m `} ;敬O֥ɼyaY.oVA^N{Qa[Tǚ`-$NjR{ )_TauR諯//H.B9[>x`>~<϶͔؏XutPK&,RYSA|streamz/dataframe/core.py=㶎MQ$fs;Ko۾}- 뱕8vIQ$N}Ė((t+ZD!"Uߋ,(/6eqe2"7Ld)Ҹ}f;$]'%Y] Fȣ@d/vLu]hws>d52ߤOiTES Mf7TJyiV$Mm:KULe~OD>;YoJ$$fN[(~EEU%_㛩lyAeɴfteC^^^ﱑʼrAc;ӮuS!-(2fA̅70БPC |DxG T(X㹣,VϞ==~po-.ufFCOB87P U735CۮDUP l΢mxZg :0&h_iгu"RS4ffMdVhJI큱/{YzߪRBLp!YsʽZЀ0Ī(mAwc6FmUU`l\FtUXӿHaj@!ǀSe#mlqA^.hj .."|P˲2?@.E*}ݡͫ?%o2ėq,w"ei@ "iace##an$TcʗHř?c85]uWoeh5'l(l|?d|Ĵ#da(sZx ERq} k?!pؗyOchRe"PwvK+X"аoހnyfp 7o)e4hF"֘2\KDRa`CY(D J!SRpf{  BYDne":",/?E^˪7h@(h+7`' y#>c7+9eRA!Wwِ(@O8g qT-0"MRZp̅vŧ&#f-rPnіLR(T!:\/1E2sKV+MDD{}A]:fI1vs~3[8_ fj.%Dϙ9JUh"e+˦_U+Ÿ=KZJ2_Dɹs-J^0(XҮӔ*Z+O̕&}J6dK/bXz̼Dr,B҆񜵙#z>AV{\^8矋d<櫫3!>B[Qi 9@j)sV*QF9zm;ȋx6lAᣕ }վvK hdA5Fp'7#&=V夻j!%FYFGο-:ONy\Xu2%^9$ o ~]"G}mZϽM;,tfvMIARwh\՛kK:W_>ʵ5+FE`n#i9V7`#(w84􏌧|17(lGƄ|:?d CFO5d4t0?@p8b k9ccȨ4ĸNࢶ;.;29}: ɝ4xgb@ w!N x16FGfSe,r RY n' ؝HXܮi3 9yDu]A" E l|IsxTjJS=@QZۦ/ˢ^)x[H7`T$dZD+YO$f-:łT#u}Lfm3Si11#"^?ݤ,5 f’-*J6S6?E/3trڦh"Q:zk"W -v_'@~_R5(?^}0o1+I|x< Ӧ W' [^\/88^u^qᵕR0}j6 -jڄcvɅ:Z7EN&&1`x"<=t2)ŠV]) ]*leltǩu|Ca:Oc!m _n$tjy #Nd@4<_~l<`( OH<8`G~Őۦ%ay>O2N"|`Ahi0M71L߹oM0^hs\J').22?b}6!߶"W 4D]FynRRD;Hv_-ev@JwLj  ֧^|f_&OWs19x.   V+qE&!P [ƣ]nvs4ӑ_^~T ju5ç XdU{7x]i1luu#B ,h̚z0ZeŠ>U-oz(nkmvz l]ި2>$r ;?$ob޹ڰVsfC %Dd s ! j9Ksq5ȿEj`i kCM]5N˴'ڰ'e^'cpL_7O2W Nk%}m"ɳ~*X2qpCK:Wmǃ?X>?9ɾEne$K*55ð7Qc`(+pg'8>l*}o E#'zlf0uㆺDhc@mX#Es_׋v?ᙅxE]x#r]vet.hK^Z;Rܤ1b3u# +ժ ((K'F~]%KQL&S4EoFFJfC74ոG@'NNŽm_[A*R^y8;sFϹO1jmP\Sl{0W/Fڄ_-#uIԉ!pYU}>Ktu!նiねuQfxhoOx<6/8]Pu 4&t,/ݞ7&/~mVC]I"hQLW&''âjޡb#<;| 1=$_zi'ayσ2-=Wչ4meOX3"صRݛ~Gg%^y#psro0+v/dcgpڐ,g(4(ԓ%dF8"ALmHFaI8'W%8S_X&1U7GFIBLGTЁ)NH88'A=F@=oG}g >fA~nNq(NѝY)5y˸5=,ӄ.bH{Fn~&F1#{@r" 'Q?jǝl TQw1;3ipiΝvFq dxe"| [F1Un.L`\D@qW A|`w?=%N275~5_?ٸy"f1:5k,2ڊ.<O]K[vO$(ve><9|Խ^*DAD4O@iI=5F5G Kċgc+{#/22tV &ݒ>Yǁ6'Nr.!E;vEiF6&,s&_XK=y)pԮ{J!U8˻hc[A2ƝOD \iuHN/Hp^1&KD3p3P[ZF*$Ǣ`ɀ"_Lk ̴;gk;([=F'v9?,bqC4tTOܸb{ڛ*4JRU۪Mtc6K34Inih_*:?̐urNLĚff{T!&8GBb;3#fig;o!:lG?u&{ox#b0~vjixZC٤Y/G~"r'r'7(Cyϛ7G̟0]8+e1=囷:?I̳RJ?+qS2=D{i7` 96!ǥ1L_&dSa^iK 軅E0rs?D ?D%t1Lc.)!-KlCTPy#v|LJJNPtٹA(_$ ?/kOVVk_2aŭRR1MxdDII k(]cT¿Uf`UQڦ%Q.sb\שR.uvO߇ <_0*>`j]V lj~@j)q_K7yzI/9G{XmMR8Uʜ +?OV$uhW`[fQg-IrZSNqg1I:Ӧ/XZ|L:X*G;,HR]JfOKf4/?hyWl|,Р>T5oȊbfWH7`#8Ek|ij״$ "Պ/Mg[* UoՖ5ĵI-g6Ӯe3bUJ3c [~=0 oqk,,2-KAա֏ڈ,1+h6SfEV/*-+U<݃䑆+ߐĻ2AUI؟=Vm_kk RfX9~hMnXfݥY\U9Oʷ$ιEHE;gtWzNSvPjlP#(p:RX,.ӊ64A7[Wb4Q"V܊6s/uQGٺ]:O*]}p_E4o/OopTw?Tlt| ąaVF'a)6-_M3-^UTC- .<eP?:)k}KIQsw_5uw~qh6`w,$YkT۹+Bs{*Nr\$ܢ256b2zԑr2YSnE"B[Q`q; >JrU&]tNAŦ.3^kMt\+7 Zt3 oNvf5f묂ˉT˱oͶNU8X5,vYl7h:Tʒ-MR"G*cYe'JgLxJn~ Lt V^rt}PK&,R+ ("s*streamz/dataframe/tests/test_dataframes.pyw {E<.t K7Qi+-͆sʆ1wMR8(sH;N.$) YR{'BC1PI h-tOwI:W D~sy8B=Ä3`)JBwTZTp,}1u״I֍i:U)*zANE(`+rnx,`!'$J efd8kljnEuEUuzye-*]H پԶc>ר!4Y-5we85,*hI…D? 8Ms`55J!6{Cj2 2[ђܤ#Kmb{o6ݥ MK#ׅ! Ayi_ݝjl@8 iϴP- ?l>j. u0/N"cU:t3+)94|N@&7 ~mhvqdc<Ɲ30)JLk%--CwZk\V`QX{P:Pm]F3%ø7ҺӔiDhAvc޶vg -t:Jibq?.XAlp = "W dL5_ҡ]Ĵ)W5Pݳ@<ͦP;= _55Ϧ8g/E&+!r ؄Y]˚N0Hpq2!ʚO%rVVľs-X")ҏp:t w񈣩~w3ClD"a;Z1#25HN{s=JLgيRѕ_1x's= >]`!k+FS lT`d0CFLnojx#9ZaEE1*b.dzBS$}vyxtb>'2͸5zr ?j1`c'dfSa6D\J s->c$86|sb@B=vAeHii[w&6>86@9 ;Wj `#c*qI9j7}ݮ(/Al/+ pr"7-/BuM#O3+@_5W":Hr˴1PQwe(%6 B-36.O] fT%D+oh/Yo!9Ixo\ 4@7] ̭boڼLch=SH ,MKj /(*ymDt,l3a,ϪӗOQGBvLZY_9VIg{ dѰAVt߱,.ikL5k+:ͤ~~-hϝGϞ#]S^Unm|]C8}:=>(^ Ypu2PE@c(` `w Psاbq- A+e؎i$eS鎱o9a4abMa#rAU君.B@C~V @ F[FGG rm!r:Th-3Yz* w,Ze*恺#l8AygCmrI9U nBiA0[CEzw ƀ\WCP,ua.GߙD+q LXlH/:b*dHMVXRDic60@~n>[0d5 a]C|>k),@%a ☪}RS'۰k쓟D>h)8S0Aw/҂;i _Z0&CnoJ'Pqƹ`c'䲦 Q;氓z|gUjHYGvKj\X!REH 1yiSá{ko#:UC! V"q䧩m A*74de'lwƦVw-@Kg[*D,܆:kʫPD:P.( J6hT{&B)#v#vgSl]xm gܙTx4i'EQkqrtnwME PUzTiôe'XpSԀ8*O_x9lVM  }H&`G[ö{ˠزn)U1e\kb֕ LqD '`Ag}-Zzҩ O_Z6OL v,*803>͋((?E!|9}kCcoU(KTFw _IBMYUIy0Yu; zD-oj+Iuv[je7 f xjɍ>yP#lRNJ8-6(Wg/o^vԪ`3nIvj)CM¢`iiޛ8 bk!n^},]VH+Үr>a+CSO(85nJoѰ3Htb:կ~5^||6D)\N?d)#AƑPGG3;ˇ_ԩD197<(OMIz޵JC!fni) f湇o.oe ) ح&T5m_aR U[įUtV7kN؉1+ae, b¾S ;;;uUN?P;&<:k*x Sa7Ic7 uR'jPb&Y_bqh$x_1 p|۸Mimprr05r&-Uu aFrvFs{:;g9{E]%+3F;f4|ثO ?9O\##5\;z<}do ?:oE7Yu6XVK0wGx4z2@(E1<91MDwt?-xs7sՊ|wT&ިs x*ofW:kOӱ*fN=*Nh!FMSV ?lt2棂{[æPVY1NWjn&Zlr_J[5dැp|q!(D6bo:VRF zk}R/]ZȫG ÕI PK`Pstreamz/tests/__init__.pyPK`P3+@streamz/tests/py3_test_core.py]n <^@PU5ov&CMG4U9fg|@A35 JlVAgRq0uu +ؕ.{LV[ I8SrwKzr@#:LK%#PKّQn|streamz/tests/test_batch.pyTM Wpr>v|PEQoQ0X@N'~)J`ff]oG 3Wuβ֚9oΤB)KXizR}fYqѢg \l2q^C^cA!إGX3&NޛC<IkdVQk,@ Y^9(T322,މ%f9F]wՁSO[K;&5zf {Ts?2617Kt+U*-b]Dr蓢])Bt0 s(9%[@؁ Y]zGއ˥ՉPO^JU9/ۥvVNьz8s9&3&> zaNv S9]nVo/#X)V!BJhQE5(˜CA>3G.PCJPoZ)2|ui<jeM&LJ }0Lj\+rL 4O0w\k D/n4[(ѲDм4SD/A:IJPKّQKIJQstreamz/tests/test_core.py=ks㸑W 4*L֦r٪Sp^ ;!ckuE뜦EDһ4km ;ڤгiD䳉UѶɀluhCUի JViǓ FY {^4ݥ{dXf+\Cj>i1A"^T 8E++Eld↎-S˚q&ӺZyDy(^YD∜ĵ.LC?4ݲt*eAu|LAT1nSqdiEaPA/!ݶ?X{HI݀X~t⓾%@ K }Kz8yXσ E8VcWPljFj H]}_Ǒ,wD{NM} Z/˹E"|0M /|odT!>?_py'01` LW6s5?[7̑iL5ebpnH pbqxx"_F!kf6YٱZ5^bqDd iAſ~d[n(>"Q)؁UH Y}CM=S}țA]) qm0k"rͪ8ϡd̋$\OyڋS<T𳈌sZDƳW]9jHUl [fR&?#@ rJ_"+x zAsYfѯdׯ&  \1xg8{DM>ξUulQȆʇ*LW?-^^9;^]9yt6:hN6ϦjR(`M'0V3!ٚ5$bv@GCq% 5=33FwK>?Cg_"IGyvÚeI+nI=bK v8YYȋ8'ͶͳMV$wY)ݪRbHX7ĘQv;R[n$0.K^[yrC k6YcDǹJ:zsR%~6Fq=mtyh]|\{>\+_p9)cG!@7s|M)T! } 2).2 K p .B#_m5˜whf]MkR [LFIC]ņ᱁c !۬@C'w=]ZׇJO3lcKQ/Ob}[EyyTWҫ;xk (\?MFF`U2dU hfBiM Pl#76 jK۪7O0nX#@ y:v%oRX@+},aWo`bNP59 /cq /هlq3_~z*v~cb)nfo6wq潞5q6l{W''mP!4̵C:{ϵ$w]x9fqHө%ҡ>w6_;X.a7{%Z-5XqCp%WCP`˘E7gHC9\|"fiu%F"ɨ{qp V@Jwu FA7g}e# ۖҸqMǝMϬXJaAL֪#N/˚[ 4Ҭi~ҦD/#r̜e6d]=ͨ5DT #HBv~**a>zv : Z}(e1m1;Qo%LeNnS)I#i}H~\Y(RecEo@66[H$p-%'ƃ,5ͷ FM [ZB"3*"1чv0!9Ko])vJQڪՀ1KaIϺܭJ+c%ZW5tݲIY,p]"Š0Yi N!JhzR9C |@Z0}*Z2I3S"bKRAgfcMC×*XsI7v+aۖDN^YEd=sLYJAlF BXQrqF"v2MYbxA)F8wD#`Ms;uE ҂mYT氦ùdu@ axT0}äx﹯.pbf4d- 4e2}$35 2eg1{ ub pzs#Ѩ{Z]Gx-)$;qCմ؆ Rszem9hdlҚ0YMqjO.,lOaU3{x=[sQk|9u}ljfNWZ=ZOZ3zyZNA&Ґ! ƒ(DX:П\d-<;WX{L|3#,ՙ13 {yCNڏ#sb!"6th&lslc1E64+|3E&*5{-#+s\qKY{0`؊ygWr4@0sum,:<ٗrLrwI(e+k|UРa=nņz'#%庳+8')gzf͈]PUx{9+T ɬ:@ >֡ sz؁_md*3_i)a6u P;<]Ó3twX̾v0ۛһ0C *akpk iƝyu.lf)Xf乂ˢ gvCh q.1H $)X) K%l4Iv/Asּ~Re3NM?]S:qu曂G=K ]@71չ MtGfR N:rSS9aXѓZSZ:0XiYI8Y֟\iEj3̥^a3!Ʉ3*3{esuߧ^8OP8w.ۗ^#=G想?5b@A,͍ EQ4˾#KA|.':o2fyV82 ߧ˺i]K@}TUu$LB%7Nli8{θ5|d̯@iU"&ZbMkI3llIk.|N{P@a"Fi4;OdLF` m3` ~%Cb;)ݢrqر! xÊT.J ^=jA;;mֆqZD znۣ|*s;PӔȜv:ai}Y7J. cUb/u-+?ZV&aj88C-˱bߦu4U q9L:0]caf\z4̅ҰԛQzf|꼼K&w} 4}#I`p I3{ҶbֆozvVSwfOYxs!sw3?۹}6zwc[R_ Ƌ* }o,ƦCE$g\QuT侪sh}kY.2$P7eɏ UEg~1[@~:lh_F >%e7r3!/X;ݪDNBWY1,kF|C}[`('{99taf%ܙ[Z6USNݬ,_Af$p'0-@TMc-\}b0[t(G(C$941HD{}ׇO[ }Uu9Fklꬤ2Q7 z]N\C?Kc}`=ўCI2~z"TT{ eBJGGN5g͵dOL B4;)LAw>~FƱXݯS#3޹"e (嫠xqRNAxL_}6嬣WL~L2M׷~*)5} I RFIBߤ*2UMQ`1 LklYf <5n15k 8i@Hh{|WHz; lI^`"8bKTԴ/FbZceAZIVٱmSM-3vQmYwZYm=v+ Ǡ{ߍ rNq˓e tKK9X?SìmBl4s2'K暳SBp.UNnZ?^-_tO>[VHmT=bzzg( yNl|QOb@\#K1hHllMȧo?xe$@^9\EaΝ4]b?ZRcYs@p }yd#wbC1Oo4CuܘVqISC(BJa1H04Qė{ƃ{]'˽k*#^Phh/o<絃~v%0 F<xGE7+=9%ϰssauɮݱ}*e2~a0vsfLg)SCc9B1s^ _aQǷT?{dT"_?޾:aD{ieB%BhQjokRc̓uK󷽉 z^isC' n% ?yFz-*¿=1 --Y,@lS7 n\=֎'%@_|_u20H& e=28jhU{0 |=]*m%j \5|u]>$`H)X(0NW k$Sk0i^/PKّQlstreamz/tests/test_dask.pyYsF_u#!I)d'OҾi4 N֍P8%gwt $NZo6|T}84bc!N(deаFBim'jE9Yʀ9ZGz W9iVkE^d܆I~ dctGD|ZD,=I`Cs$'v&h4]iKYQW@&mLT(m`6,%" 8xj&#OYT HlU.VϬ&ZiEZb- ɽ~ 7+1}kTgu*}Dāsk4];PXPD#]6lz(29KnlQ"ri"~% \j3P<k#!f$W%(q㐤\J5F8jG~ "MJ1Z1ޔ";Lt; ۋ E<K bVKr .6U"z_cR̓"\Ƒ[ֆ{"/CؖHYiT(=ı rc@}$~zHDLqq"%ǕzKCK,2`PJVAQF491>Dj{`Db=wrs\Ò@Ϸn]XβaN={VJ( Н}0)z=nmv:#,gqv.ɇ8>p ?y0,¥WpA##7/'r vF%>K뚆 cLd(а,ŪjʹفҘʠWzH=rwWn%'u<,ujQQގZ]ntanb:Kw8 L D|*_ y^\\hPZFތwHb ةRq)Bʂ엷LeLi*bAFp,sq_&K4Mb3=Nܩ>L '&7e,BDNdɱ)7]d*zP^ZsRߴ^2Pj|90D(zn,Ug% f9d]ZZdhV׵g Pr'42-Rb]ƿk͢^LKaFظ(Ja)OuP#6jת2_}$gؒtpw'=2G`ñlլ mKT{mv0w  ␀l > c)Ɔ$_#N:s ~IY~ y9^Au(4t-&0 {t^dPE}ӓ֦D{0Y봭h'4Ki׌jk>,W'g7jlul;o~rIT=H!42,[q}s{QɤVa1:L?E98{Q&fٽ]1H &aI_7I5a0}0$ ~tGob㹳ID[,;|=~v-1d3ZVɕMxpEw?PKّQx/wzstreamz/tests/test_graph.pyUK0WPj5aBi/c Aǎ-KwF8͡ IQњZLTݘ1)UFñyv`];gsLkdC'QTu-4`?k2lV6=*{:DG얬 n UAmV(߹(r(n/Md1\ EMna.p]ܔ]P$ 3f${(M(z.jpr'BX|ЄZXwk'Nbҋ=*b4ve)Sv:'n7>-@&rja<1=Ok;2[}L8)%XbgY[swf Wվ]@A sFK fΚ@Lj36Jֻ\-ci(<)!y*q8İB4NW`R:Nn/SYN7WagRJ}U}9{ܸiX- g.8ec !hZӆ;^6ޙ# Tj,ěo!o/=z 8~e'=kpA X/A"/.rLeS7PKّQ`streamz/tests/test_kafka.pykoF~AR+1"eZ:\GMg*M)vԢfA.)Rl9R;ݝcIL4#^F?7O%]&G՝yW4Pл^iqS1%L_^K}!X\IflIDYF^멮h,R#/os|K4!X6xϞ܎-a_o б<5[-sa3D~sBw^ڛ_{3vco_|?`sF7,#f}ë?wfYCbY2|YS_Ó{>ÜFL :,k#oI"H ς8CR k/tp#;888Deق\DL2'xp 4rT%ž ŕC挆]0A'zY  lA)8e|C6JuC:o#17{B.8,]P)=)"B?4X!\G4 W,[edy K T4MDI1`q//IYBE^y*5B͓cW '߁s?-xS gq%yևY6F4n'@Sza?W;@Oh.%B>(9b>{y )O@ ʚ8+堲"{BGBU_iVڜJ 9Ð$|L ?ȧ%G 4( 7 ߎuO0Xr`n_^}8{swgS'!QwΦQh$4b/ E ZALR#4 iB4 4DBOSzXנĜ4`>+?Xm"W\簂3 ~zgUP6Rzᇟ߾};@{p5M4] 3, =r}j]aP@s4c޿kA\CNt?{ x); C R5ON B ;_N5guU-.AEj݃ѐx7`ːU=pgZa_G4):_ .q`Ŀ߫ Kl$/]e "0v@o/@w) xx_Uꏾ%x fEq)nZSRg!rዾ3g71Ca)Doҋ H?WJM9\JRKc6RN_kN*jrzp o b Զ$hPʱs1h|Nq.O'Cd )u$ɦ@r(ޜa\r7ߝ]dкJXk}u,2t~K0 Y>!%CHb xrZbnGȄd 1 jVbgT`BlQFs`_q#[!uRvz9 ?95sO$uCtNy-%]vm.ǠDrzϺ[w;0 ij[} nһD{ܼS4"p;n,FU9\Y0]WGG xƾUIW>=ħaOO|t>|O}}O0D4 ͪU&Z`zFF4s(_uTP4Xi/u;$Ù>2\v~i=u U]5Vx>LFڌC}Xn+J3`>pLg*nE'0HWt'燕2 HCfD6AYt5C3e¯4s\n( |NS7"D:@'б^C{tX \KHE)@fq<ͮ;%+fS0yWRneV@ !]V>k@2ՎUY~Eu K/ 4'*lvNert'Hgh3JUUoTY/4jK5\=oͩiI!bS|_?ki~8oהdq!w w']Zh!Ͱ8GA:D_HeE[H}3_3 wJ-HS{rx=qćhoEם~_!-J?:sHRqkZ&L_en2c8 Wěg"t Kh"*Ʀ4e5x}l[r *5Vd9ojko9¢8d1TYPQ"- Aw~Ku`P͙nT ^dŻ?^g_%l(-p [׷Mp}(!SśUtM$Ut[9\p0ݺ(Zv<)/ eÖ&HE-8ڝK;jY2qtGvUmQ[9_G ϻftVBjc?6x$i \{&Mԣ&.YGGtNx4#Y @sb׽kU(hШt-1b|(Ǐ`439 vHn^$螔0krWJDq4Sµl[欽4ҹv9w#S\uuuad׫2~ìZf$eKc?!j1Xw7MƁ,1!=C_@!Cv21"؛ާ]\uh׀vBO I*D R V([8blzR_coVRZR iL"nDop楲_=/ԃܠHi9|2X(1S%x'[}HUbՏ\>yOz̻”|$&əV\vM ^  Th&BW@qpֽk]*zje>},m[;"6 KXqhfФr^שww KWQm_jj j8wo5KBmuCYjPBPk`tR6Ϥ) k yR$ Bx_?vmm1ھG %E\|g458R+jR]r[?PKّQ -Hcstreamz/tests/test_plugins.pyN <&Md5&۩N@`Y^Ja~3gg=q4@aywG@lv<[vt>/3B7vx6w ]13ĥD$5Av\4ȴrګtO#1:rbUc.o6(Lg ^:< JUϧ (QT \OgGMded4f f"'yӖ h!P|6i{cR= \8'6ύeot!ac˞+B)|इȬ[`hёmV](B@uIi 4%ME.Xcr4_\BpWO/Vny=^t*OX"Yg:: ^L9M~zWl;0T  C9olfoD}7TJ ÿcYS ʡ{py`cJ.4R>^h{+bDl[O|ļ4{9?( --3FQ yÐj1a"򜽸[qK%с|,~PK&,R;}streamz/tests/test_sources.pyXmo6_(DbMPѢHb] 4 Zct׏oCڢ{NGV`/F s)*0gxᶻht&J{-%?ޕXɂҕL!Zc\p"Œ`P9TIEI Oȃ: WO\ة2REiUzVXgҢI +,bk%`Nt4$%?f(`_L !*7k*QmTnE$+XU]1_T.4 8I@Vfkxlά)u* Wߢw.Fz?i!8'pDB(=L\"ţ}3L(ݎ4{4t(6l'UwxNKL; rCm=ڋy@M+bȟvG7 %w?[R}xdg}k;eu;p${em!Ւ0j!.5||9%mZȢ>xHF-[䗩X'(B/<';PK^4u-lqԚ Oes'0=k) TCآ*Mv? ug7YP$>kH`8xxs|ˉݎ^:I~pM$vixJ# \zg*ng`^N 8%5Q F-ш|!\#&Dnv]nsfAYm)զ4* a8MָX8P?WGlbiܐ"#DAme, 8+I<O>|O>9,'~Ӥ%+D#+^[%ϊI w v, o~wژWq?D4Ų+6V#` 51+EqBDtb8i fv1C+"H&|1}')yaI5 b̻ɥ8,NbF_'3{|$ͧ#5mO׿PK.R/e#streamz-0.6.2.dist-info/LICENSE.txtSn8+=5@DKM@&$GEHTvN7-^1g{oOϓcw0F?.llO91vЎ=t4gt>f7=6˴|)aL]0e\zc;}|0DBk q O >?Nُ߈]ij\ J =-sDEއ'J:3Y|3;8;~pndÕ(_M^D[7h퀙 6ɷٴvEHS vpD'炌jxr pcNI !:8#;<,8bs8goz.^Mt)fnv4kDKXn9>hZت%JŪ >02J0yPĮ!f nO#) J2rj ;-d+Q {HDJa j(i]+3U STLxyq";.--w*^rMԿY%تA(ԼEL AQ Ӈ1340 %۱ J Gp%E(uf6F2l7BL21< `@01<˄\릶B\]A [dI*@Ƀ}-wܰ̒S,0Xaph4Jl,8e7*a@\lHrZWEX+FWo˙`iݷPK.Ra streamz-0.6.2.dist-info/METADATATr6}Wdt6V2$VKrE K(b={.(`yit _{*G?֫<-mKX^|2=e[vBeQ2tkv: +:\ WBGpc굒h/*wmZ'`E֤=|ϴ7񻤽VV%B(zHwoy&}(!1F=eNm^><3Q6x!#(U\b f>,&?%qZ/O{\HY[pļ G*Amt:wlYA$eo% j:*oGk !qJoTuIݞzX)s?QSafp~e|ttHFB|@g+F=*ïkDoSKzI;s 5,Ycj}ъ r2cG"B3$u[|B{5>G9ױY퀓W J8L!SkȆ=|fcaz1XTFf@: qXcZ'vy"bOKlcXdr) go:"3-:LLUy,hG_k\BPK.Rȝ_nstreamz-0.6.2.dist-info/WHEEL HM K-*ϳR03rOK-J,/RHJ,./Q0363 /, (-JLR()*M ILR(4KM̫#DPK.RYr %streamz-0.6.2.dist-info/top_level.txt+.)JM̭PK.Rtt streamz-0.6.2.dist-info/RECORDǶH}? Tbx#CmجA @!TI,tHpVЅ?R<Г6:T K¾ڶY2WE+c!'H O] =Uc̓9wt56f/Θo'mBd9Kp~k5Lrm-N APM d`#H>bz/ W$FpfvPvf/?!UP1F=VVr2եfr|阢 }&lc!o:٘k5S6%%A#4Ve @S78N}7Kgr5 8&o^ Xa|pr28rkĶca+ /z:pE<|$EtdB :kD0ۺU*Eq|(=3cWy\lJtǴIc02R_P8g륋,{: DlnlyŴ-@17vP_j1OQO$|G>,wf.ݮ]0 @"^?M:XqƵk3x .@R]7,>YqdD0МuPnt:)(]V3tVa,9Q >!^y?h2f"i ~qQT-kmX@G] OVBy~uldٕܪ"( foϵ0 4J#yjJf =A\岻9M -ݻx7nѯߺت|%I-t[YĮě%o 7h_ ˘šAE5Pc0|9%}@w0g1`F9QTF?I$M|4=r6a&]`ٍ ɼ(OcA ƽu3?~{{FtջeI4MNN:G*kL7l^LJii;35%cp:Kk)`yGxȥ5i4-qB |tЁ $Yں1<1IVS0W\AáqYBE${ؗA^`uLۖ >m+T^BBZao:md]p^Hx6mv}?F3[8PKѥ.R:2ر3streamz/__init__.pyPKّQTP streamz/batch.pyPK&,R'b#streamz/collection.pyPK&,R~ٶv=7, streamz/core.pyPKّQ.d"Dstreamz/dask.pyPKّQH nJstreamz/graph.pyPK`P;DZWUstreamz/orderedweakset.pyPKQ@x7Wstreamz/plugins.pyPKّQ/)l+ hXstreamz/sinks.pyPK[Q+j'kj]streamz/sources.pyPKّQpt0 ystreamz/utils.pyPKّQ ?{streamz/utils_test.pyPKّQ#Eystreamz/dataframe/__init__.pyPKّQ=R ?!pstreamz/dataframe/aggregations.pyPK&,RYSA|streamz/dataframe/core.pyPKS(R~.3streamz/dataframe/utils.pyPKّQBˡ /Kstreamz/dataframe/tests/test_dataframe_utils.pyPK&,R+ ("s*Nstreamz/dataframe/tests/test_dataframes.pyPK`Pstreamz/tests/__init__.pyPK`P3+@streamz/tests/py3_test_core.pyPKّQn|Xstreamz/tests/test_batch.pyPKّQKIJQ streamz/tests/test_core.pyPKّQlstreamz/tests/test_dask.pyPKّQx/wzstreamz/tests/test_graph.pyPKّQ`vstreamz/tests/test_kafka.pyPKّQ -Hc<streamz/tests/test_plugins.pyPKّQx?'Kstreamz/tests/test_sinks.pyPK&,R;}wstreamz/tests/test_sources.pyPK.R/e#streamz-0.6.2.dist-info/LICENSE.txtPK.Ra &streamz-0.6.2.dist-info/METADATAPK.Rȝ_n streamz-0.6.2.dist-info/WHEELPK.RYr % streamz-0.6.2.dist-info/top_level.txtPK.Rtt h streamz-0.6.2.dist-info/RECORDPK!!D