PKuDS ٱ3streamz/__init__.pye 0 yA>@]6[[t۹MDs}JIRhYP_oum:g$kzP4kX/>Цƺn"L[? 9~+0-B 0olj:J1\l]] PKmRTP 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 Rm4Y#streamz/collection.pyZmo6_A,c V`]5/hʒJRa}IޚFfE=;ޝ}30,r6Y g F2Sc✑,ҳb@K\l;_}e`Q=;A{\Df g۔Ym9|(z ,4Ek,")ٓLpoQn)Ay)Raz@` U ^Ir"%zO!r_XKJ?m Z onF#ψ(&U帶"E^D`! ^6'A TtLSMsl3}^|c9$)C&.I?"IЇDg3 ^:Cjr= G8 肕djIa0FT8*C&ptWtsiN/YD›$[MIdJ8_asXe\c D4_B<#UD8 $P1{gNt jsVm̌ 5 F8Y2-ގlXކU%BHo`V}Wْsl.p-=& jo\P ,h fζ*Qd/ Mk쓮j5) &=A5MjVݦ͠=:n-Y+e 6ze)WRwNkveVSr#=kXOͦvWn3?RS^Gmn:dNTkau`Vcs<q`:H 2;sr o[Zns|j J~Qׅ4M<4a{ %R_.-N]IAcvwY}Ch=K(MyzsM:\ %9G~!svΑ % |((tى}?#eYѢc[Vtu)[g^fywu5kakJtKdy'a1pZEmvO6$Q=G(<(H/z^(}RרHb^ݤ~w77Z-dH(/=:"-3Pv%yNN !/T)#γb =\Z`WF}qLHҵ˻JHW1vvQEނh= K$'`|E@i*1ZCwBy yL.&$5*!EX^nwv0^R&xgo uom.DY* [ZuV`*ޛP:rԽT<5~׵VSG" نG):^<;Qa>4S Ѭ`*Q}$mhQ ֩37kS5 uQ[.0#ꤤ7}q vkF@p+>[]^9։̭bfm5fkO)$&Պ:_JL /j۶_%6k2TVmEcPK+Sy^~.6streamz/core.py}s+0tH:-I?0SDZL$>g4@5h}~R 'Hnoooooowoo^W("Kڼ*(__lh(?|nUvQgqŨtr;E qo(#mjPI2N+ &+磢J(z<4G e򪨪,/]ȸ_''m<4͛g6KGIgeG?O&qfb??6Iҳ($Z2 FmVS!8* xεYԈi<h.vFUfu4GWY{rRVK@wvVVgYdhdBx@AT!X2'2^f :a_]q-E]պ#<<2_CYK+d]@H P(4J"QMr_7.h'BZ韁1` K_*n h2-!TGCM45[k1V׭[iٲ*@_*FC QZeeb|DwT 'P)z͟%aq P7PosL@j8 [n ,m-6ESB'Dq)(c%Fnd]5]$Vz|y?"LP,OY] ZB!FMCB{SV$'D<>f>];X*pQ^KDaU+bqaqk(UsꞢU-]FXiK3\nGd y#IN3y4}A[* A&H=cWM0G‚ O40A1kYZ n^TÐSRWZJ[w:YvK=̶*,*b1h^5РJHG. g$@VEEJ&-,j[ .$9EY&FujUUA>x9#㕶 LD Gn$wb^Kz`7l`.bCVUNV ZnxX} RAq6*U8 miߣi\ZQw.lNv>: pS$U'N ߌʃv=2>Cl㦇-?ELjlIZT1j]a=8 vzYf\vEQpqx]u ^(ӛ+0tegw> e2C-@*qjԫͣҍ9<^UDqt#~Y>9#xۺ< bpnax<2>~X!]mv`9 %se L2<&LH­jT W yUuo|@Yf]j2Pjת:bbòc 9qf(j2BKxi(>uے!fsBeTZ[\KB ۈn`9 1,u"IE$s~ ZXż.PgKglybKF/K}Ex W! u$ҏ#1e +`nTFZ[.C"ߒ@E8p%BH^ E+ !540 LocPQ9{=?Q HdT*goQc ,y&h )PghR-zt-.g9`8(ȶsAx'Q 3LU @{W\;/DΜl/WEf@찠IT9)648QP\?JSiHk̹렏ꍖ 鼌aq,כƛO,{6%.{Re'JV/M‚MMVW3/')4M Ed/ne-9Z7 a-QJĦRTw㿏g=gOZ C?Wy`sڲkNH44EjFGYçIUTJ.`QsKT5>H @)#'8hVꡨAdWu?J,ozeKʟmc~+$ʈ;w4'?Fk Jfmvk]W]px<`4ٰMs#ظ~n^!`1K0XBs1RH`v9u~\=?=lvMNN] ~puO["i.E슣ڬME@U!Myax\)l,fV8bC_Hs$Q7ڟyNkը 'R8;]d&Acd<<\ƀn RgKḼ&:Cx$Bnz} _xE'!hNM_ 2^D1C f`!T5 >`Ez%=mAKT{{;6]g{>N)n`O4=߁v(J_3rHK籈۠EO}qpȦ),ཧ0v@sap,N)x=6H }j}2HGE>ksUm7 0ƓhRIcfxũӱ({u~݅ȗхٻz0Vquqy=}k 'I >IsAv&-ݠd PouP>&QRوL^wjYQs>ZSjf==O18s/ڌ ~$BxRQ[\YͶ?@.QA+!udY]A`?__r*Xx(>4ŀ }(ĕ8)B٧o@sqVy_8r8ƅ5ɩ q1^s[a@.dT m‚I=r{#­'nWNs ->=z{*&MPC|>Cl8&Ikc9q@uBK`GNWeh_R62HO6 {~$'\U&E'AR1Se<1C' ˔0ջ}ý#҂!D>64xsZiߗP%di9qQ4rV%9z6Y0(Ǹqbq .ֻ'uF2(<q$r 6\ k(Rl]Ǝe!k'mZl``.[[5ąh {Bה+ ЯHy_ @KBu>lu*BF%)&?o$! dD|m`[Оʖ#\6;ZplWyBљt## ߺ 䙭[r/\ZQSe3~HE"4QcUpF :Q@6m/p mo֒ƌ؞uٝBn \tTSBl-5o2zrDbB,3RH(Ht$\œyaHQ^{LQ/ưu\BX7Dƣy^ vE1j/) ͠s"Aʎ#%@Ğ®@1^sVsN"0ݒda F,y Ə'vy FV? G-_WChn=N^[l5Yм1F5sWq4U Ԩ!rO T&wk/\gD[#YpL˂ c]39or~y6oq$.̤d{˭IE@Y Mrגˣ=`R1| cMVd`vsPETC02kTgup/{ѱ1CX [s> }Ic7[uNѰTc᫰y3Ń%gs}IZ$YxW:jU j;Zf0G#{_lZ#:K&J`PW_AeYy$aqF¤[|0`1,n>qs [pWAsg3oY}&5q՝u-k,^|&ʎV:y7b9]+zŞyB'!0K}UZtEn!!#{Q28ɉ' I39B"_`)l"U9#ϋL/%(贜v]  RtT@R+Q ޶#zyr7/Nmqґ͇ύJ4 jxrf'pFA9x|{dIV,}5R+%l *z@7uXvb*NGؤW#3Y>z8Nl XoJG".Q\U;:0clG'!Ug1VPowhrl|(LTs=PX#Սyqnh"ǜǩPG,wJTidcvs c ÂQ/Be-|ɯ2o&,@)t#B$uyv 44},(&P~eD0 D̓|!jurmCªIf|Ny3ږC6_*YaIU`ZT"}#0OE%5%~~CpD,L(}PsslE3wjJLut<_%{۲,tIS8kOtieP`;!aAoiI+L Xe5ƕ7Q.KTGDkN2ԛlP5H[TT42fݰ1 xhNFV)h@孄. "6XYu9Fv0F}5c#BMhx(OrRAEqZ4:}2?/V yFDc. x0M<ľg)+v0!1=jsPJK3~5Ӡ%XչѧSB@n~9gKI LQ6 ~v*u"fdjY%1I&M`sRAΉKPYP-GeJޗDMslT0AEIa.HZ5& (wlEJx$n:@*JD}N(,%͠"tt'5n3F -SaKUǍ #i׬нx}ʸe$r?;kJr#lW:PmmQ?Q85 ? *:pEhc0t:Cjb_C'y!˃C}(c۹6oosOxX|Ut5CaMP= \lØ};ㅏgۊoPOsN'3A^7p5Uoө&ηM6WP gl$fq\|waha?Avޏg۽)l!]|(⣷"ԿzKlK8A85̨]ڏ&o{}c<!lCdl]j=RVC%sz%!D`]_QCi j$1»Ag]^Wm8he-nUh*cK_+l)%J{$G|p ޣCJ Q <,(%.;:*H23˄o&Fn2f%(`-_% Wc^FO|:d*X5eVahIFuD;!-/I2X+EXEX"ȳ_*_1\Â-{,co e`9~ wYAgP'{tm,Rt"GՑӶ;GlMǾ it19̌yEWsQ+<6ox*!sꉦ> /+'fi0D$>^`:;ΐ_CHGa,ٵY¹Z tioD}Pf P g+.vgo^2JeJl'W򕵥Aƨcq4LB4:ю V& aFhl:p$O0B8\?'4M6/6頰nl(b~ڮ 08P J*Z݆b?-m8s) H@3 j(ln)]>Ҥ~v˓ד7AɮZ,.vPtSzXwU6GС=ǣM4ς~:~/~}NN?ܱY816iF2ހ/dRQ\cY\-i4Pŕ߯wRr΢%^h~ɭ&2|P;uqm$xҠ+V;.*2GaʁjPd13o G"%LW XpS1egڊ+.uL:z/4+X74PpY ?(A,vM>ʋ֩w'8>`os9:6w>`+7?L~'/:uE͙o;O4SE,!ֱXE S)ZYīl[AA %wnP3GO?K8 8cY-蒉8*7 * ³ϸ7Q5 S,}=S2AmdS OMIͳ>d9|Qj(KEّmxS{DBLLt$D4QGEtv=Z/.Jwvzn{Uխ`G_A= fL>l 2 .S8a5CaV;b9&*o`Xθq݅1u_x)$~Z-g]u:Mn N3q07x ܂ݟf"[fqTֲC?ƉV ep7SsGp58\uϩ*Au!v3ge2= -CYq!3NQ2͚Ind}#ZY\;e"ޕ/EVwnRBZxkGHJg@-ɚn:0]+I='5(]8e'eAUgQ$VtWrDU\I2x; qdG/hht?2%9m@VJEBp7b&QZo -W$./.n!t\2msȠ@7Q6xuUހ.lA{}~!uY$/tWr5h48 KSbCeJ)V`g]c.J<~J0p21ݻ?ADВb3_W|`=ݐcO3,,eqH!z俴nS&m#9QzҭR=jfE[ 2 h(=[1_n_cPP.j5G[Kᑕ/#W*kGeܿ$&tŕAI3[OéG ~]W|s7Ml< *[@Xa}GbR'a*I;$2Eq1nɦs[o\;z߆HrD"Ćtg3P(<<ǞSwV-]$µO.$jm%*­UWɳ%>}` n^ߣCoO(DCH4.{ԢN ?e 'QvMsʁIeQd|@`Kxi4!vi8g=?UIfnECC@D/'M iq%;\íS gGUϋy|M1m:wf{&˼Hn6KTet!3~B,~@ew"eժ.'o7mlUf$m@Bks}u.4ƷJnzuos%71Cſ;D8P/_m}ʷa63_-(^ԶxnCP~D<Q㭺@^2oNKl75dq'Cf.]䎮* ^}r}&7zq [x`R&7Le/uߣ[d]F'xK 0G#j&_}߱J mw0 939ch`7 /Eֿ\erVit=j- Ut["`Djp6VE2oJZv=^RPpN%R K+D)ŕzҶ՚W|Q:h}A㩪H3pb&:Nd煭ҪurejuFk#*bDg9t( Gxy*܅/JzB$b1}C[Je髿}|ܱԮAzĩL7&>6~<'%շÄUla2oйCw ӂ?/,wQ:P)eƬ&oؗk?9:ٷj :Qu:<.l`ز:cE9m.#[GG{41_rNſnޭl%k ]#tdGG19)WY:ph-*3D BJ}8X@^9$u?J_`⊄q釫= 48,0{vk5O[oLWx`f[&זպ)4O G}K_4"BN'}E2:'ɞq|=LpQqN2Yitb|xA! 0 V/n[x1Px眒C`l]n0kzAdt:da]xGɗ\\*84C <12[_ZrAbLpn`UuނIَq P>WB'Ał%`1}` -Q߆n#U>7Fgx͑7K^yJp=S7dP7am{ȓ7z 4B3B4lˆΐv-.9$|r]5d5nlDИ /8ƒ\.,0I,$, >qa6#( J˼2֭y^E??La 97vbRR%t &"[iH e +dP/162G F )fP?CͩCbHOPK Rz7\streamz/dask.pyXM6WC@Ѧ-K[t2-R Rk;3$%QwޤX g3Xm2&Z7ѲNUF(Tn}6+ Apn Xa R(^AM+M[+kBal#hERR%ohJs@qmUt0&3rɍa? ^}W3 .%HfF7goazhae+j)8vj>;3SjME/\k0YĨ2 5>&-!WF$ ZL#*x E*%45sqДn*.}-rN m28۰5- !!&ro&B3_'WanzQ*]`O;^^~͆tB%l6~&dAw*>qvHŁdp/ęSb,!ektL1F4M4z= ׁOͲY&9on =S> NBgRi3m,!D[ Z Mkb V1}WRO))7xu0DcS" L/%l߰TZ2^#s!u㨑'-wGlNں(yx5ve}[f -,F[u,-*3.+9Vv2voʃx_=n$_&[5M/fZSpw"MQ/2c6rB5Jk]+@_.娱ߞ!i91./ KOkx>9H? d)} w [vlƓV8,ꭡ[" %F$DsQM(GaPWtϾa)@#$>svtQLqlC_~[#zeg)|Vhl ]4Ngʮ5"['&N!2t͌ PV魋{Ibcs+)y 6@ž@E!i!Pi׸aeGF^yͥuߧ=VɜK ?>!7{cZ)ݚ%1m,n .OJNTf^D6#i2.0vZ'яznj^6+cx.u%]duA P W -T<6>nfhxlL CZuWv߰e[H|K9eÆDa64t$^>rd!KW- z9t30~{ )>wT|ݑ;XA=po}aAEO*+"OnanfxuH# e3t}vKX0w ;)vtPK|kǃope ;/@ u}O hB)^/:>K;dg) e')X~&x5q KnȺ3>z 'P"rѱ,SÌ'~ R2 ;K`W5PKmRH 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ҿ)PKmR/)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ᧉuPKmR+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 Rj0Q streamz/utils_test.pyVKk9a4A {1t]`CB#wWFR%~'{)sR=$8.Z{Rkx$"'ITKM8 9VHq!EJHë&[mot2@Lhw&&ǩ=)(E1(+*wmAE$;#f 1P푫FbaޗXn1`񈶬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 tCaQX hgo@U I`L{к<93 pz9Յzh*`h: ˉݗxW~ >V1D>3(r8̌(툯q&8m,͖k#|e*oCoxo/OYDǗMCi]b7ۚs YD/`Om|VũEjRi[\ P=C4U?ݙ.g'# OMl΅ KvwMyͮo] 2)O./3mȻF/V z~n~aI#12c'ItumG4G ?ؗR2{)< 6x..+;~ꠀ~\L̰M^t-<^^*]l܋NˆR]ϡ#^NQʎ{o! oy/^ c#)P#ő@aMGVH4ׇ]zMbώ;P2^g4;dyqBۉpW1\UKqǸʋrkIK0@@`Hځv|CF_%󋩒({~󯑂؃l ITc{LrG2/  G>MSTrĥҁ@'Dl ӬS 3g`A^lNxx U+[H`eT,󄙩#$.:= +풟("ZB'-fmDNH̵ "DV U q kzA^Ct |,ʜZ$vC=R$ᆒ).kI 4܂pVWET!c#/:XtEd ~Rbf!{$T҈:5 /TҸ9DkKk su7U)&ڮp #1b }ac1)DOƷ^cp%yrmUJW+^Ӂ> ,%UѮT y %Nn}d䞱Ҏ&5 j ( Uۙ#,B+l'I}j໽(2٢]EC@!ZfЍ`D`@yj|BaPEpVp[ ⧷L^  fjYvn{nwBMSV'n,RS,>6|! ~Ac_/w1=_d.$??Lf|nbnך:T+ʹ2K]9U0oO@8ZIWb6bo,Tu,%1~q]sk$SyfR]~/1$)K(N0\G\qmb0K),! !dE(2\} 55` BWH[z9 7D(.w#_)>Aß" _@m8 ' ]hqml+V%MNo=ppw-| Bgg#Lpw~ɅyC`uvYR3VbNVν5 ۽Na:Ŷz_Po Ƭ F[} < U<'}Bޮ(c`1>(r9KxgR\_$ֱ%cwcwJC UE.w߾vNƃLg☴EsRh@UoN< U-/.Ai/[qgF羇ITJ:aXs=ƒE9/dhު؊Z68 i{cӮ;7*b]nb Zc;]s|j[}/jgDѯ7ES riŌbT{Y,ŹC}K}dq=a{RcgI ;7ځ`hA~}c'"4SPˏk9nJ`΋ (8~v,T+G`϶$*+9cb!u̠k zK, ǿTS=/̇ٶr vbPK Ry]streamz/dataframe/core.py=k6W:uyݭYrh'5HlWc$  7eՈIVewUܔ٪*")\&MV Wdu4MѮ7;$~T?k2}h ESxw3md=3RϳǬ겭izA?uad)zOw1EN^qx-yJQ-LH#3fyr !13zAɫN%y\K-Dӫ3ʕʶHZNu׋ c7/9UZOAV!WWժD_8g I# R@w;ي̅zŧjrH7q^ͽb@pM.EDf\2;_ fj!%D-9Jh"JejSs_ELiUWҡ:ڽR|eo̓A"^hq3c}֓}E׉D}HɆl)5],;KEL!*HcqewzfvΒI bAR7h_\[hKS _G AZ1k]xok^9j_|g+>>n}ј;/ct-9<=ȥ5:\9*;-w{6fdZv*etb)t4Q'nw@OXͩ}bsS0 5tBs8,ߪqE?O 0z@  @Dt."pGBQ'MG𷣁ǂ# rk  8# l{!v_x2-y@[2¸&eޮyb RY]s:$)Hմx\/aw zMSN^ɝE8 v-N"JV=q-4`exdm#͐IQ>"9X"54%(Z6Ffn:)b%oeY. ϬZL:'#.hG,SD2?[e,` f-}::CE֌W_AL;k%EMxQ+d28 xi4D'/~ 1FC -oS$q)N͑8mZ0)r@x PŪWb+##zm"NF=RBOZuBӍ1cR%:s@0f{՞:LWXs}S+/ؔ ^)oleltǡurCLMt6&7cڌ[H6hy =SNt@4<_~l<`(sOH4᥁H WzsE:=m6:E0YιQS/1/wr ycz/osi`|'eړ`mؓ_.FcpL_?4-Ȉ'u0>2j?S!*,C \К6iYfqqSG'l{46CNol[G=+6m0h2E>~gr ܻ ,wace[MsQHSZ2M'Z瘺!PֈG_oⲛ$Q#bnrɪ&*[C%B|ZF/ΎG$h,@TRAOAJ-$8(ʒvbI܋Ie H:T l}@CP4z-e%l5t"χ^k  =E?ƨqbۣQ[]FRumLkY$MAC^|\g5B۪X3 [yPh̯OEN+wj`.(}`e1f!*v0E@ޫFՇ:#G+O+ L./.doNƍTUU m+Jhxoؤt.*w -~ba/nФÏbBbl݉M0 Z`XTzT|gr!fdvNKء{az(E0_M`%:5>j bn$/ǶTZnMFvG8۹W7XMd2LcQA8mߗ3M2=K :&MXHFaI8'gP%8CߠX!S'r&%X<3\9B"8 j10LRcz6.,?%(|t :lrseܚvSYJG |rY xɳ8~BcH<9]ݐ]]H5r? HE;#-z5c ,oKk̑xs^/;VSX +)a.4ʼhO! Omy!ߏ [0N Pb}P=׿􇿃c7κ $ iJjd+zN-10(LݘUȮ{rWdhW_RV?b6kQn{Qɽgzַ9GG H^Lro7PrJw ަn:Ki[CMꞎjq9pDg蘺?`$^quXuw*vBU<>+@ΚFW We>ǰ]C/0^_ Nt?(T@dAHKK]iu[Iq!>Sh0rsg"pТGV{jz9$>_s/ՏXTP{gvM/0"*~*.oS33ǰ314p4?wXT&3Ab3%.kmC^BoOqFR.(~T]]  Ps쐒yB'&F RXz_P`x{ `? ox;09k2&>~oo|'}8#uY 9=.s¥#sooYJwOl]5|dOm)&U lo7؛魀LM96V։t3*Lapx鵪^-$ڪ:܋.z>@>n=zr#>!~[9wnm! ñ v($G|bh`|3F—E(Q="\G0E'Zؙ[mqonr pmL gwwrasa;bϔ d.wv' ,4aNs.[z7N&u 7 ̈O b~G 3p9GƤ:gp 'e,,Hp^1OD3WpohU.avEd9b z6 DtB@ӺHewX19{J`a|IOW?}>v{tjp{4w^؃x}i7R^b|uTv{ fxVar?a89 ayZ=Ok:r"iVQ9iȿɿߍ;R?E"`;Gg̝(79 ?o*״SEۉ _@t&mUɢQ&.ÎF} a5&D2HIde[m&qdO|ŃJzXø#MQE~!#(ne=di J$v02W >^H@Uc|ɣzM7J26:[LԻԘ\W| AEoOwj`ΪC5 ڪ9 ĽR~s:ςh -I #I ?!0tA?G+ܺ%IRN[tpraLeqPN{Ŵb@ AQf?V;Zƛ,s g|sMOٗto5"x bP X$+EVey)aN$OX2v$ "Պ/Mc[|T[ަb.AL JDD}ōӬ`L6f̊L&_$uU= __+&7{HcfbrYOf< ߒ8妯>(Bz&.NhHCYQjlP#[)pRXocD m&iuѨ+1pע_~ myS6qa.ozW_B #+Zcs`JU4Lh`-em;2T|_#[t#\qQCÆ7ZzQV^iVb5ym܈r•n2 3χ"<*P:[3M| Fq5wR5/) ?#&imA"WQ.%~"6KIDOlŏ^ZTnʭ#"'=q}}Nξc:9B] C+#Z &fMx(9OPOQ<#J>?MʫvEk+|M]LUHd:F銂(_␬4Iwa!!q(`uqUvZPF1_X4֐Xkq挱sqá93B"8xf$I?lhMDG%9Pktr &B-lN=j3DۏB@ *6GMp3\'Э[3d<$%u7C2oX`tu0m.h=m-/S?Athnע[]$*g ec8 *wۤp Q \HRA^@{ V@%)9n}14D~oMay#13L8˱n:#v$zGEe@P R_'xCKn]{9:;;YJ1>F彈7nD%I4wjQf詋W1ͬl JsFzm?pIiS ~. ~&w8l4oiF>I!nJaHg9'QB(48]-fRcSv(M/ZTX>=Զcר!4Y-te85,* hIBhu9dF =>Z7z S-hILinґFK6}3Z|G|q%͑^;/g)4HZ3-T&cFO3ρ ḳͽ1`'1ON"Ӊtw# 'M,9I]rq fwW%zA Lْ~Kt2[N&^KHiA!1ei`A\@wN]P`PJS;QbXړG'7Й&(s ާ \;,RS7|8TUkj XytD6_i;ACC[O@1iS"\jgyP; _5gSгëhQ "H6!`scYӽƶI.&0+dqZYݹQ.ˊ" 'nqjQρ~;vxGM]x g #hՏnj'cw"vH}TG@ GOe(٨۷`,;FEkHt=o>2c"*uv+$]|BS$}8'`)XuKP7tI"*B+[tܽvwE0ymJZ98{9\ @lBpb>gyGa p v؜n iqJ1> 8VWFua8.lo{vRG`d^xfP*pNX {b# igڄʆ\ViӦrgvH<ԷJəMxVp(gTL .a8H& ~Ql-E]X'Ď9LXlH/:UTɐ w۬z%׉l`)qTP5p9nVu }H&`E[öGePlm rUhLGqucM  Lͤ4xȡ8̮q>' J<@Z摉kZbOnU[{wqZn }ĬEYB456^%{? g{raN1CQUGĖwHR]nx<xCa.ͥdCY^FTXxPqoRǎ7--ES o,˧U`' v.mXU%3-GϮߜWvH;m8#YvTvA9uLo r82Na ߡqkQސa'g*^_t_?Sjl.D9dӥܞOo8-u*Qi6M΍7voH71J/ GTH3ewJm ܣ7WK7m2UZ VgqVQ7A/0iч|1C2@<7?@oS~ T-{|gf8UߥR)mEsC5:):WK>5K͗D0s&o4Ɵta"ǡc3>n}.Ӹ_ 5@=Ns}cȸ29dR )Se/ԀPIܖ&);oS 추]x 1CUرj`>,X(QX^v7ki3PYBz]Ac#tU!͈Y2i 4IK ZNݘyEQΛȩ]!c;Z^w7tWoW]WwWϹ뺻6ÿ:j,aK!6o!aowO?<|2{PˌJEg H7Xi=uM^N{~/ؿ)N桩Y˝*0#9;9bN)_J^_))gT?혱9co)xŭ~S.H} (Z =^ت}do,nt`-K~ןnOp%m} 6{7[3ng0eKفiyij<jfYu2g` % q Q.NvZoTW"DA`Td_d4?g}Nt. ,/sX4e{Z^,\ ß>Eն_}{a_C$x6dϻy paCn,g*^Fǂ}cמW^'jۯoV݆i4zهGZ_ eᦂnx73]]Q[8䰊$V% B%QאG9lG\}@QKzd,{>6@qxkP3*@4o=~FѠ& "neeSc ^{}'߽?qތKb7BOr^ ߆j]܏oGf[0DGRu Kkϑt8".)czx>WR΀2$whҭzbĨbzMS'pn5 = hW|{9nu璆<N)CǝSz'}_&]6P }o _Ϛbm5{od^V23]G^/l&Ϝ`o1˛g8wD'2>:昉NvNyc(RO9պc8n ,.*v1մ&OZK{rЇavSOBMW|L[lVAgRq0uu +ؕ.{LV[ I8SrwKzr@#:LK%#PKmRn|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:IJPKxRGjstreamz/tests/test_core.py=ks㸑W 4*zx&gU.[u.;u( H A-onINrUٖF4 pS[NjZg[Jj47,싴.˜]RYf5xz#+ *JR)Lz1 a9;;Ԕod*u9{oʼ,w ໿^%+lH{3 7S/]x}6-2d9uIWH#.F4"v#&z_u!oIQ~J.ȷ"?iN""C-$"ĩi[g@]t ̩͚nBūexrb {xŸDM @aPOYc$>NJ9.[Za[68HV*)n\ې<۬g!#) jrv3NRN!<PkAU tm" bVX'}GˁVD[H[6Lj.Qfa>r>{NՅ+LsP(ĠPvNod(#Y|!;n#R N>4%8k<\m./GX.yGHFu/3PN;9O"l ƥ~P~=As9 )&LR2[R%\r\l{6sH)!&mD~gɚuVvMטc\<&tZ_/߯ Ga(*{c~.9Ңf}A?}^EZ6i>DlU T8ϡd,8d1DH|ĩgY洰gg3wƩ=vk"NݳQ+H¡5[;> /p ^UR_Q07 곟[avK_Lv!0yf 5wSG#;ZPVhjد|LӐՑ1eՕs}9T]M*SW4cKal9rb,XG]*쐠`=grؚrع@wK>?Cg_٢IGyvK5ǂy%`&L9@)C˘pֳ԰Ҹ#q S,G; ZDd֢?LK lͯM%e$g/:M̓sfXS6q*qI*jy6oB?х7cɵ5jW`r6{/t)-7OC:߅y\`[As%nц[mFSj1o&+"+&{FɌ%Fݮ &"ex\]VܡSxOKWZmr1{ ;]U垉)<wjP>jD`e :ؘ,wXⅥG jJת7t_U`ώ'j 7fl< pGsMR(M,Е9+`bNkjI^6匘c/q-/هlqs_~ݦT>$_s9|9{=k|jPNOҘBj^Yhd*YKoiH\Y© ik,ō"M6W-|msz-˅㹷Zl"\vZhZ! :8_̓˫!s(0`ẹւ3$á [>MsO|0 և v 'Qdw9x+ VЅ%[G>sg$WWc;#c#ǨG >ihz)ZT;l#ȐZw< 0Y}'3U1O=sU1%B}Nd\2!C>;P>I ΎS{O}ӰۭhjWrTYat6ۘHM.tbzQ$ʊgh넍&hg[J`\14~g~mm//@LͭpCKG(&bd *q&SLEa׳nH 4M&Gh.\ 7S`>8qb6+E%%?Qhj忀Ygd읚S>vu )c=&η`qhH3ym{c6U@URS@=qbfT48xE43Ş S(E[BC7 }c7̶lΐykoSBlNbj1V,FI)G dJc=b߮ aƶ95ja$3I(ںl9OGT%"N4AyWo=寢,>:ft ;yä>k4:IDV*mߗ/0Zɏ+" T$%,XQ["諵K[8rGIx|#`)On0R`ъRA&WYَ>tk3)Z[fID0~n˞/|SȺV]qeX}4x5A&UMOZnW y"1LګqY\^E>0G3Asqg3;R ^*FIVXd (dTr˥m$Le/ʥ#,I} 1Ir_ v\*Bض!QWrf gy)K mMbvaW <*.>.VHMpI3To@7# 箼hlWtޮp>0M]1Bw 춬rO麍@T[\ڣy<*k aREWR81t3N²` ᘾNP؆f22ڳG8XO߄E8H6*)p@&@:,|-M퉩{w- ɡjZnCY^9v՜OY;hdlRFRպq'VLհ*;^({Mu|>omjv-lsH3zyZNAM /%CL @9ED Pjt? K̮[zvZ1?n d,E95>U{ߴNF:E"h8o?+!"P4 =:T[dnQ0 ۘ}%eӥեa13B( Azg gCjѦnyF> SFwxs2cB!%Es'vbk .bLFhҞcA-Fw̤CY0QWI%,-y$j?z T[<&%=zDRlWOJ6<֘v8?4Q\ME''}z`RD2:Zy 6W ~Wj:n&-$x䷤tve$'0OxZ9uUӼEkeU:a _M"qZ7nִ_(S8wYq;6Eխޜb U~ó3P<%o@{PѹC=/Em$/t0SjfhTgKiht:bh[Jf_;M]!^?Qu ξ:6x F0rvl}KqN,A%uzpd&L4LH{FV²5*l0;8g+XvU\xM3:zH _wqD޽cp#q6K LD8-G," T=\eBH-j>(8kcp| ٰ=ʬ,pgJvLL ~&ʸZh޼,+ԲjXM?** 0vtױ} Ne/燘L8v|{z'b;.-HK~.=7dJ* sƞdԙC Nb$_Q# P;iźz,gԄ$έlSϘNJ_-D!@ۇmlz3@asS f+H~k/eUw#wIc!25ͪ/y9<_ˤ:JYd.Ndoq=/)c 'gнbODH` |bM ݖ`R4 ,?SBqV$Gu.ISiX+{V .k0@|T֖޵ќ놝,ԦXF`0T7j' $^/䜱2k;ÜtQ#z&v;,ajldgzAcq-z鞧ϖպE:XN5l<6Hhl:pUv!mc%j^Z̠ePKmRlstreamz/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?PKmRx/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"/.rLeS7PKmR`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[?PKmR -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%с|,~PKmR;}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׿PKuDS/e#streamz-0.6.3.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ݷPKuDS>} streamz-0.6.3.dist-info/METADATATr6}Wdg6V2$VKrE9 K$(b={.)`yit Wb=#~"?%,}/4=e[vBeQ2tkv: k:\ BGpk굒h/*wmZ'`I֤=|}0񻤽QV%|Y|\|g!n(fH<>ؘfO6/>3Q6x!#ӻ(U\b f>,&?n%qZO{\HY[pļ G*Amt:wlYA$eo% j:*oGk !p2!꺓={#RaH+z P7΅lJm`Wpz̅_7T_w7~M-'v(Ըvd=%V G+rk*ʝˌ>8 z{]g %w^fN^)*0Luf#^I &%VVF`Q/i#ʰ0: {JM- `Z%pKПW"!x sRȑs8l٧b"I%6-~ (πa=9$vKlcXdr) go:"=-]gR*<Or{5u!PKuDSȝ_nstreamz-0.6.3.dist-info/WHEEL HM K-*ϳR03rOK-J,/RHJ,./Q0363 /, (-JLR()*M ILR(4KM̫#DPKuDSYr %streamz-0.6.3.dist-info/top_level.txt+.)JM̭PKuDSOet streamz-0.6.3.dist-info/RECORDuǺVyNeHL^sx;ag4Qs3 c!8Wȗv2*y3 0%G`D'R @!_Mq,t-6=qoBˀT5+zj.C%3xA) ]]Tt&_=FJ|@m":e *%sh_!}qb'o`Om~GSUJ}-w ;5JJz\VfùnNur$  YO3@PdCԿSb`ao>aǃ n<+m @"$!I4YӨEĂ>ZXJjA$H/U ys4?_$GKqGx eT{0j&=8Ǣ^n 2a>-N[$e.9)( ?njpEnunrV1:ftZ`Ӛ~G9K-Nv8[fR5$-ui3&/ t|tW\"X&aٹ]^d#Gš0"RWSt&ԌZ,FsD2i83 Y" 5mIfcL(ˆ45xBjѵ4R bYlmuf21n0 oU RjB(ؐ_z8X gi5CɬK(A=Gc{)Qa"o\_4/@urG';Og|R "*Zh\* krl0Q EX 蟾32.QAS!~vvZBjI!ە?i?:0;$֊Жĕ]:jp]7ܚ޸(=Y&gװ5u^hZ8IH8I?M Y̊{B|U]ܥLj`UjG`Qt/gh4?oB5h,mu]FAѣ`y42=.y`b`xnT NݕU4+A1n*}0Vk*RfnWܥxG}2RE/&%Ӵ؉bn%%rH>1tw:^#Q>mBUJ#ۑ΀jzj` ~QG{coȕ;AM1\s`Rn - Awom` E|_I1N`^?Uy5m&)Nl r4 Z~=5B7ОGBomC*Qm)@ZDd:.!;cࢿ]bۛ߯Cl]K2ovnC0HDT>%_BӺTOQڦ#XF ^Ѵ;_\~KPKuDS ٱ3streamz/__init__.pyPKmRTP streamz/batch.pyPK Rm4Y#streamz/collection.pyPK+Sy^~.6 streamz/core.pyPK Rz7\ Dstreamz/dask.pyPKmRH nJstreamz/graph.pyPK`P;DZ} w streamz-0.6.3.dist-info/METADATAPKuDSȝ_nstreamz-0.6.3.dist-info/WHEELPKuDSYr %lstreamz-0.6.3.dist-info/top_level.txtPKuDSOet streamz-0.6.3.dist-info/RECORDPK!!D