merge.scala

  override def query(q: String) = {
    import net.liftweb.json._
    import net.liftweb.json.JsonDSL._
    import net.liftweb.json.Serialization.{read, write}
    implicit val formats = DefaultFormats
    
    val futures = clients.map(_.query(q).map(hr => {
      val list = (parse(hr.getContent.toString("UTF-8")) \ "results").children
      list.map(_.extract[String])
    }))

    Future.collect(futures).map(responses => {
      val json = ("success" -> true) ~ ("results" -> responses.flatten.toList)
      val response = new DefaultHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK)
      response.setContent(copiedBuffer(compact(render(json)), UTF_8))
      response
    })
  }