Pavel Chlupacek pchlupacek

pchlupacek / gist:7395481

Created November 10, 2013 08:34

Memory leak example

	package scalaz.stream

	import org.scalacheck.Prop._
	import org.scalacheck.Properties
	import scala.concurrent.SyncVar
	import scalaz.\/
	import scalaz.stream.Process._
	import scalaz.stream.async.mutable.Queue
	import java.util.concurrent.{TimeUnit, Executors}

pchlupacek / ProcessQueue.scala

Last active December 20, 2015 21:39

Attempt to integrate process with outside world in nonblocking way

	package com.spinoco.util.streams

	import java.util.concurrent.{LinkedBlockingQueue, ConcurrentLinkedQueue}

	import scalaz.stream.Process
	import scalaz.stream.processes._

	import java.util.concurrent.atomic.{AtomicInteger, AtomicReference}
	import scalaz.concurrent.Task
	import scalaz.\/

pchlupacek / Conversion.scala

Created July 15, 2013 17:09 — forked from YoEight/Conversion.scala

	package deiko

	import scala.concurrent.Future
	import scala.concurrent.duration.Duration
	import scalaz.concurrent.Task
	import scalaz.stream._
	import play.api.libs.iteratee._
	import Process._

	object Conversion {