gistfile1.scala

import scalaz.stream._
import scalaz.concurrent.Task

object test {

  val P = Process

  def logger: Sink[Task,String] = io.stdOutLines

  def one: Writer[Task, String, Int] = P.tell("Running one")

  def two: Writer[Task, String, Int] = P.tell("Running two")

  def process: Process[Task, Int] = one.flatMap(a => two).drainW(logger)

  def task: Task[Unit] = {
    process.run
  }

  def main(args: Array[String]) = {
    task.run
  }

}