import scalaz.stream.async
val q = async.unboundedQueue[Int]
val src = q.dequeue
// Thread 1
q.enqueue(1) // ordinary side-effecting calls
q.enqueue(2)
...
q.close
// Thread 2
src: Process[Task,Int]
src.take(10).to(snk).run
Created
October 18, 2015 00:15
-
-
Save xanderdunn/63895e426f1344b53ece to your computer and use it in GitHub Desktop.
Example of difficult code sample
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
133hsgd (news ) 12778x8( 29x9 ) 12 var) = var12 od _2wks + news 121223437edd (control)-q21 x 212 x 126535743934=22wsrufbfj varctionn + 1212siis sis(fire ) diakoa xm+dkska dis+ launch//.and//anmd12374578393902940y85838587y4893974887334368783+w3922w9d89329498e9389=28w2878198291fy8728937SASS)trweifrrac12,fuse36463874563447377487872ede478376837698u78678(reload)dj1 3-0yt5503-0495-0 +2309302-0edgfidjjkjfhdriu b+ero90oer traction 174623762343874 ]16482439839d (hack)dbqqk 13532733684 code eriwow seruce (seruce source)_mdeekd mode)dk=1`12824de78rdfjsfjaw dgfgfur4ri484948rrr8f84utr9(varction 2 ) barth3fdosd453675454448544457343354877376478fbabthh)x=231322545094 source12w=(emma)elpe e125r4367638343434343547348783734473w7463743473848398e82i4873946873492348378334789857736475736463764634638738785836y343684632847875486736487478974984453l=2367e6734634374893747837747387373923sdy877r7bchdfgdhfhgkcoopeopropwe984 atrhyrtjuehf=dedhsahdjydi217362637rt57489430537490758364897447365463358756364664756457584657463895474854754763684693756755655-0445909054599-4959-059-9-x=2373782342387294828e38e9w3789d398488932748937289472312904374043489823308947383042194938237348284788482730823-450434430975074335846357469475986487re89er787we6w7894763287439875734658985987985512354235653t533655t32y65654556
53654656435544354646355465343t21g355642y1246465655456455652461555645556658665669756685568655t654650-56060i96587i8597ttoi98urtoi894594089574905485047985784897437987489745968975475678475^7w292332=-e0430843940327804iu3978+w39898493894893823298439r9dr389483847309382093=2030583099403278948382830829e90394890ie09374208322479837273984689e78237740834093829083329084928398-31-392300035805698598r09584874736486347634764364278378946894746474378463844554354438554354653411438545434543556554554435553546586576956859858595879*89w4838432848340940-34403494405-043304-7&192390399W2-04-400W9-430RI33890489343
25344683454487344544434864987843434444
7weW324424WIEU327489324093288947284732473740398903509485943-885905804985438584095890(02W92898328IS9392I039t6523=++_Q2903-2-W02-34ODHFHIREFYUIO438FJRYE4IT9I9TR YIAOIOI2 vcarcotpo[m 22iocosdaifedfjdsl;gfk(q2w2^)w2ckkdjfdweiwe53546754354535445544rt45455446698i5968905688934754985685096809450698590589050945094305984383449054854757454985789675646455655
65646566^0we0o349543pr-0-543r4 4 5ow+we3-03-0-43555687640854957698456o9456456445645665*9ir0493092390140495985968495875874574358473543875847587476874745837884874567565%53737831012-3103-0384828247287473848784723w4888(network)///ei3r8d8r9389r739r434984958349+ey387483287edu384e7387483 ecutaotppn v iti090907893894783