scalaz-stream echo server

echoz.scala

import java.net.InetSocketAddress
import scala.concurrent.Task
import scalaz.stream._

object Main {
  def main(args: Array[String]): Unit = {
    val address = new InetSocketAddress(45678)
    implicit val cg = nio.DefaultAsynchronousChannelGroup
    val s: Process[Task, Process[Task, Unit]] = nio.server(address).map { client =>
      client.flatMap { ex =>
        ex.read.to(ex.write).onFailure { e => Process.empty }
      }
    }
    merge.mergeN(s).run.run
  }
}