withSocketAsync

withSocket.scala

  def withSocketAsync[A](s: => Socket)
                        (f: (Socket,java.io.Reader,java.io.Writer) => A)
  : Future[A] = {
    val promise = Promise[A]()
    val sock = s
    async {
      try {
        val in = new InputStreamReader(sock.getInputStream, "utf-8")
        val out = new OutputStreamWriter(sock.getOutputStream, "utf-8")
        try {
          promise.success(f(sock, in, out))
        } finally {
          out.close()
          in.close()
          sock.close()
        }
      } catch {
        case t: Throwable => e("failed", t); promise.failure(t)
      }
    }
    promise.future
  }