FutureConverter.scala

/**
 * Reactive Converter of Scala's Future[A] object to com.twitter.util.Future[A] object.
 * 
 * Usage:
 * 
 * val s = new Service[Req, Rep] with FutureConverter {
 *   def apply(req: Req): Future[Rep] = {
 *     val f = ... // a Scala Future
 *     f.toTwitterFuture
 *   }
 * }
 */
import scala.concurrent.{Future => ScalaFuture}
import com.twitter.util.{Promise, Future}

trait FutureConverter {
  implicit class ScalaToTwitter[A](f: ScalaFuture[A]) {
    def toTwitterFuture: Future[A] = {
      val p = Promise[A]
      f.onComplete {
        case Success(result) => p.setValue(result)
        case Failure(t) => p.setException(t)
      }

      p
    }
  }
}