NetworkComponent.scala

  type Transaction = mutable.Builder[Any, _]

  def transaction[R](fn: Transaction => R): Future[NetworkSession] = {
    val builder = List.newBuilder[Any]
    fn(builder)

    @tailrec
    def rec(fut: Future[NetworkSession], buf: List[Any]): Future[NetworkSession] = buf match {
      case head :: tail => rec(fut flatMap {_.write(head)}, tail)
      case Nil => fut
    }

    rec(Future(this), builder.result()) flatMap {_.flush()}
  }