gistfile1.txt

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

object WriterProps {
  def convert[A](str: Stream[A]): Process0[A] = str match {
    case hd #:: tail => emit(hd) ++ convert(tail)
    case _ => halt
  }
  def main (args: Array[String]): Unit = {
    convert(Stream(0, 1) map { i =>
      if (i % 2 == 0) i else throw new java.lang.Exception("odd:" + i)
    })
    ()
  }
}