PK[QKc streamz/dask.pyVn0WXلj4RV]vvWUc#?2I؀= Eec9l(ْl ʒג[IfRSL4ͦq ET 3Ak9YʹQl E3pjh^TRi6ä#l6SW<+vCAm f2Pu8<[ 5K]!;A5RKɯ/=~kz#R1I{9a+E5g58%:<΅S|a-ԋ1R؊WJe\'cPK[QK\w_7streamz/graph.pyXmo_1@ʑ黠Z`$@/1bR+r%mLryKrޙ}3/h4zX :#*aװ mxcn֣ld yLx[ Ugx'PB6hh 243'>JY eVGÝggg%_B^T5O&)ֳ/IxCT9,yŚ)Vt`Ulڮ4]͕(" 𧂷:%֔0+85a+t~WA`dׂ\Ңmk$RPBxBX5098+cK-= 4s3H.._+ rn*nZ $L[m|l)z$V_SI#q0ir %$d|79pyW3y^r`8P2\W/oʝZy+ne NWh+dݩZy,ٗ#]c(gT0.{Y$f5mik(NxԜ[qPQ=NΈ48uAW`̒zB6tﮗ0rqVِi)JS|^|^c^pvzύ8"6Jo(EՆs'|_g3|%}HbY#.)j|W;_ܼRr иy%Fmv]*v6Ջ9})v}Quއ]o]r--1{ ?q}L)+8Jϝe?XFV * hy͟ƞ:i%7S,HbIqnFG>iѬCt<Ru"Xƪ.t6 } ru&iPK[QK=Zurstreamz/compatibility.py @ D"= ~I-[]⩹y`~dG!)CczT-5 @ߋ9,@(Q1:u콃eߘʼч I e:PKXKO$streamz/collection.pyZ[o6~ׯ < WH %dh;a݀{h,$;$E-as>~Fdd\"V%5q -g{$$'x՝_m'Aj-%h}'yR)$1KFAlr,D A,dFFgXTHni2ABZ=Ch ȑKT XO@BH…~}SVGQ=*PMI 5" ,++tӭVBE  KnI;#g/2@ ֝ HnTqqBB`cg+9Pj>Q$x6I:!0mQpL!gzMeCI Vf` ͷr KDx%sVgs_ &zBJuTA  q%)Zuec3m6Jڴ͡o6վzŵfqO\2<[ϗ"7۝ZQ}~FhʜNhDw  غDͺm[<-IB쀽 /g"+^ȡW[AG].zMFzi{rTu`?{e_TcB]ɣ,qˮDb^|=3k#C'K4h &|~kV+m$Kk+R1I>Jeu07<;,U}h, _ .`Q~.9F*bt0Fۢ=;{$?*ky[zRJt 躒fQoƟwW7}WVBw]Iˣܱ"I(s|}g`_M3-z+|Cu'; [ fН7ê4L(9$Vru-qIِ<pɌf4^ Ηe^^}^_\\G)HL+H^65Zt&Q5} \!{*Ë*3 U:wva4tO=D={ㄛ.55;IV+tc8wsv1;"B'Kelt>fk1'Ś՛:KYWZ'1/)M}'S45V[N:C:T1\\}6ga.՟ 1暌8LF㨴xxqс΀JFgb>\v'DrXb'H)T'q*`[6ʧu~9;sO'-G:Cw8^)|'}`B'"B7ҙ쑻s.-.!вgaeh&<{I.gFWq F MCk_n-[ z̫R|[y^ԆUL=M_g1Γ>SY4ՕY*&Et7"/ y-ĺ.G'0c͍9ⶫ=i@϶Gr./:/ɤ6%MnU;ϩNB)t`7gMR׫q;o^m+4(.V?PKZLK'Q@ streamz/batch.pyVo6~_q,n/h ҷbP(dHݑ2%M~|Q5Q k/zE'f*e7F}9`&˲Z &J3Z[_ ,Y#Ӄ(Wc[m@a 3囨6{U7g%0`슽J41RySXB4YmU{NĪ'͕9+FTi$6P q7ƒh/Qc!9h>߾yXl=RGiۀGX89} SVлXE0vDNBdy!;fvDӻO+f Ֆ;H_U3" DSѨ4pdxS4) >yh,( jz .,R.KX# =: 3A rOUb]qEXBf ۀ,- ݑdR6BŏOD,Zb Ğ D\#߱Pj Yg,U1L褈B &JI몬(Ŏ`PKGXKFstreamz/__init__.py]A @ Es RJq)ӅkiL;I/<b- !B(?..NQ#5$hyCXh o*>r@&RygC gdpLEXt!N$=TmmʽPKXKhxstreamz/core.py=is9v+mHz${(˩\תlR*UE>$Sy>Dʖg²E<<< ,"Mݔ2Zoɼ*1TݫJTlJ _hEIzPG#4MjY4E9Y(<Ȋ[ߚڏ;[^2IT{])GtN7)Qɝ9 aUJ2&Gj ܙayd&DEn(@V Q-Q@]zY* cX@osj#* [9EYM Ʊ~6MiFIMr-j8:~_Gxd!ΡWy`shzAջ@8#ejSQeT^Mt.i>[=@kKhbgI 4q")e~%?O25CcT`q,Ѡd*$uuBH8{t HaN9URI nh-'(;:~xO=>Do=`3`Ild>&Ǚ8c(mLdDFkb|ND5or x>l^^!8 0-Gb_,quvq=tCL@>tOoSpݼ6fMXCѮ8 U xx 8 MA-Z7;~ ULOl5 ŜL?ߪE݉l"~)PnU(F&vКoneKt/:)`Bkr!lM(aɩZ %$ ) }IfxuO444SƖ"ZYEDҲ-o %m# 9NG@ߛ%]Big)jyQ(Tz pr꘼S֣w(tOVSR+:9 b[k/wvB]3=yth?yȔuvx0U}RU81ۚTs@SMP)Ž쟣^ٔw s,+eMĿW7  A)n%<-vzH@qhK ۱ЯЛv#d 3gT pAYsyԥٸ&u!z˥n*ەA޺}XŊ<; @_4,YDl/@  ,o9Y,`h28mW0/Ewq]]{ 3[ph!f6sfUN7[ꨱڠ2ܖu=;/`p3~:BwSq_W"p`=5n>%-(Y NwEei4-v0vb:paD)/UT )<^{w)ƣENv 3)kX$S$IwZ'mE~ʢabi,m(64R=Fg}xƔQ])~΋T^l 0NKj (68$}7"P*l&f"7Y[^ Xݥ_||s+ܙZns H<.ėH~]_ -󼼏%ZFXp=ϫ˪tY0.lEADZ&|Zۤ) B|o~'hK9=bn V iԋ>e&$EPy^8l1< 4pʂ4FYlmfq7ݣ=(@xEC3| Ka1پ\oV߭2SA/_>?/|DrBԑfAS-2)٣mc#&"5IR;3P.OW.t' ; E[)Afr00ѕC=z`|hoo/4n^:p=TmB-Bh\@\!Wrz54*,ET`K4'y]A !2mBk7 NU%i_QG<{}o.5E_B1ڗP~'jrp[-O8'G ?ϛ$U>YrPi?R* zU OJS{N_/W2mگ&,|p-ܟTx{`+B\M\R0#*ʨ`}[-waiu +y x*,5c%tI)6" qi g$]8vm[wN?$vԽ K7gB1+YG A&oȏeݞ=ʖi`ppǓ6y%&TlNBP$m(γ?I$I]ԘO)`٭aivbYA'=bMCn)`[[K  tMc@>ZS\? 7> N <>9l1Q0ㅊ/ļ(2P 4~Q_Q'[h8 9,ХlI1yFM"d!D$RD@+3x2E3l~}y gb{û44dN9fa$6aQT .>oæ(3E= q)[t-X,J7pG6oZssE: 5s?"aUFa?GJPs˃~2ƭ8^Nū\b*&TMu|xgѼ ܧL6؜4Awi L?g< a<T=\aʼe'1rȟ[_=T?c8~/7LOtxlffwg~f> GW1 #dj#83x5oӳyدXLA.;x@fRFzi+ёDOJݮNY(E!h60wdQx9Hy_DL^%q?-0U2h]mCXɦ-)p$Mc\D͓3bG'tS)gNyX?eBѸ|Qi eyÄh 2)X׽^S*dHSj!JWM@)]3Lќut&()hzӦ4.<c>!Յm8. vI9GrĎYk,~[7SAvG G[NíO$3%G'DUfk-4dɂH'%[ TŠ,߭IPlM7ԖjJ  (~)Oh\p6[+2uxCL_ &,ڊ#Lnq8k: bTaa.Vd oXMB2he/4D+HU149-7 FAaܖ8=x5į%{1OL=ujny ޡn8ux7I=P-V\׽q-#^ bX ܁oy{@ԴWS x'2;Rfȋ(2\ylrq?ѓik Gv.)sFl7h85P3K^ %5Q]}o$Bj _7ǞpD!`6$TĞvؕG 9@tN׸uQ: I,.(Fe6\ZcP< .3i)ra25<`\1|Y kfOp'6P?0:,߀/X ^׵g^Xs Uo]akp6-!!dfqOEt`l>6AL af5~ރ.17Q jﰧSnGqф6 am ;>U?rS6KwBi6N~ϓƦ"&қQSqM;_^_olmdgr2ȗ9M4 0m+V53G47a:5Nrw5¥E7q_(\,x+F&^oSSn]*8,~Vɡl aeU^^nBU]v K@r™>1XGUmBq nnDcڃe#o Z U9*vNDz'7b'`gk=ID jɝWrx LLjщt Kk¸y q˟ڵ +(3D'D>̚Y-j5v[,&x|CtǟVKb|>Yּ݊3k* =" nhMS_Pu\%pw{cņ4mDa}f#1l}}>ؙsBںoP!F$ܩpjFpoE1``!D>^RLue3QLCAT2෯L1;lJ+l] |:s=GFxi\(Ǣgl})43ԒG<~B[Y) |#|]䫀+` ugH[8]5_d~˅]eT'9f"#S鑃\Zg.Tz>X%#'R9;fcxC 8\e S;GG/kt5 7hɤtGaȈ=lil]F.ޯ*hTE Bh0H}$eJŀ )pDQropjS/l Fa`i$lv|8ÆJq0BB{Wk%4!77 ?oC:p%Ѿ`°6k^ҿpl[aD7N)Bz+\z{BJ=4m9bs%uXkPm}P ?EL'Dʒ U܁1 *шN =ۄ[^֗-g7X5}Yl0&=i6S{,F2NcQݩ Xrx:w+09DجE—s..BJg%at{Nѣ4VCM@&Db:H8D>M'ؿHT%UQtnEzD9IlCeJT㽬Ovmڶh5?W⑗Q]m [0]'s~cHȱ ]|`RŰ0!G=nЮmaj. lVEOb#>!z M^HwcwR:9#fREד9*fXgtdJ )"5]˻uoTj4Ŗ(޺w{q/phJ og6UcN8SyDu%|>D<~T w蠖ht2_e|LNa~$G&~nigJP=.oF?UVV=j$M1|jmᨵ[&ƖQU &3$ҿ8UD"rTS/Ӂ)&FX >W[pvhj/L15_ u?PK[QKܮ 2Hstreamz/dataframe.py\[#~_ZI ll'lxa0ж)gZv=#b{&b$G0vR*ůlogʵbb_F:k {+kdZ6b!^_8G)VQU.lkTY!S!K)k½¼HsYݷeL]R*x ry9V\}.Y =1^=4zD}Vj9%)w(3QZ=/ wd\E]/K0 B>, SB-zj|%ukɲی\xʿ8$l \lNw} .< fou-;ȢEX:obE3cTged xGf8aCPiگ9B.9 {P-gA:@Vvf›lh\bь(r@[g iqG싂gbCtb tPf Fdr 4:ݜ΍>?HSj&?HըD^aF,vҾ5սXNκa]^]^^bB۝^~/_==Uo~l!+oߑ@%7!dsGG"/RwDyE=eN:)3 !T0<3z7j]ZuؙJu.}\9^]Q &VCd[U Vj}㰗R^EQo 7b6|l`z$nTaK\`aI7|A\J ][ϯ-Dq8fF2F7 zKE+dvXe[tWUDU pu h&V҃w_̃ـ?&\Y1#IGig3/h v f, $2|4#x#ا4R6"\ ؑa`;,`,qid, %#X&b>4/E~%9v㄄ְfU/.0$-NZ,, Eɗ?4-#6u!t~ 8sђbӳ0?HzEbszLWIO fRvG, 31LL]Oa^YY"d5MIq5#s@ &m=.$s7vr¤~Q2&!"ckv04XV{ ]d=!ax?#D Gim2d~NY/E@+;L&aIA0S?"n\ؼ'2BOh /P;_Lȱ{/"+nu>v}ˋ>= ZPCBh{j3t\o}#mӖ%#-r@Pi&46( i*J|~u}TSӳ57vس]X_DpڀmѤS9THjX*[DzYH4.ۈ7`d*oپt&_~%`~_]CoBPfF ث٣3Wz'je*&2n-,6!h#DCT qo% .W_-`Y wpy/oSЧnh@@yO.Κ `Jx@v0O޻(k~"̈́($֭4 :#aQQOIA*PfadŞ/ݟw LHޟXji9C"q$:ǬA(|` "` ic #fB3 MB1JBč^^DS@{aJgy.fCQ:Ys:@/p9:K htR\>K jq|}&a}:fy*FgsdDh-ֶkm&DCt! :Ύ| h; >=@A߬2-ˠ)mmK߷#EH`;0,bFmzc ,6@vB(RnEaw0]ߙRC[E!/+ma 5>*Pw(Xi(sa[-خ)L"{xJJ  !y!~wk=Q:0=}?ag[5:Ղ͎rՃAl ( cznT]B_l])UYs.Qjeհf=١?BH~9|e,܆㒽Ы c9צ!8{*@c~`(o'jL;{Bܤ=I]Xum 8CF1>Q!DpvG0E!g;K۰iwis4ʼnv(PJ`M5IEXw$<\gS9i_3+Ո{~9J:[sFm]8"h}웅Ix&}ii;a10)8C) ]Ҳ9>_%_`q9rꏟvm˺5tQBhdZ桫MT9kto$>jXyK.nRO!l?U'ۨ|]xZʞllY c{7 |x$5hxĝ?nK%ԙ\=kJea1r)U&ҕWDCnjHԼ_Y LeXQFEa άJ)VwKtMU{7w;,4$-thQy`''hO eE˗|b3x$%6 .ilD.jX``r1Հ!D%xC=UUw0̄N[2˩񡢡=L.#+buM.71M%}ZʯL|0907r?&Y)ȓ5v@O3ȡl+e>0a4Q=$Ip[5S!CL|lOXXz⋋Nb}5/ gL #ոFJ@yc>"BB '~ab\ů9ۥ=S{~N]p@UOik|d? ^f A ضhzG .юIؤQȲn%5'<嬲 EÅ;,vZNPg֓n5,og'1h ۯ] ^kÑ"sיxlK7 X9`W:|)*4}dG]=Tt9)aל_bFy8klN oh2@<h#aj[t]Y"@!':/ؚk ;1t{ nnā61~ {EwIiiœn#24"؟hnO<@)ajmNـM,F5>/؟{MVr*6XV y`X6 X&5Fs4ڞĖa+HuVeU`dW7t ?,Q6-_}Ns=2jj? 0@~rzI`^w#KtȳJG)ry;E״)E).A~ǰ 5{ S~i[.@yG!ߥ}5\ Phxw3zvQV}kY6*F_\@y葺~{EUZ; nu~l,X a\\_[VsxxLgiN{El@"˩u!6N|$#)vwFItL[֣% "7 d+hN|t}3bAPOvx7T'v\PUr^w.QUOuzΊN*tjkX&VEmXSĦ8_PKZLK]+fstreamz/utils_test.pyTM0 W!v0B/ -Ba=xell[d}8d搏'zR-ԊF@V䊿IFTf&~ʶ &IH+^Qp&tu?_~$I7I+q`TVh)wM䐲>k,f> gB♙|}NBee-f!v JtHU`SMo9’B'a+a|gFeh:u +`iǾĖcyVK$!*%}kpjs&e˭]ߎlt*#H]a^b/;17z1kP{fndጳ[-oH^s+7rzwċ_)DQ[\dx|Jkܰ l [JAn ,qUƚV3ac1pR/]] E]}|: n0ϣ]9<߄| ËZ-1w85nc‰N 1ɦ~3Q 6 dܝ'S8#D1--MqS]$PK\XK[5\'streamz-0.2.0.dist-info/DESCRIPTION.rstQAn0+Co4RB^zmXwAJ X4R`lu I(aߙkhCz2. Q.ckz,NDx\ |)+bNp|͎gi %ƱXPIS5O/wgm^%&FB/+2XG07ֻ̙:DCIo܏JUfGJktLSJ IT{mׁ+gÐmPK\XKD{-%streamz-0.2.0.dist-info/metadata.jsonMN0E%H(+C j١*rQca7 K]zg\vff GX03rh\uOΖqT j:%3#/2ԙQdv*ld$Fk;'s;#f]V7fu 쟈RMw%PK\XK(. -2streamz-0.2.0.dist-info/RECORD}ɎHH&f_sf5l}Al6`wՅzTsO}FDB4dQ( 7݂