Konwersja Scala Przyszłość na Twitter Przyszłość

Question

Używam Finagle jako serwera WWW, który chcę zwrócić Scala-Futures z mojej logiki aplikacji. Jak przekonwertować scala.concurrent.Future na com.twitter.util.Future, oczywiście w sposób nieblokujący?

Answer 1

nie tyle środowisko do testowania, ale tutaj jest to, co piszę dla "com.twitter" %% "finagle-http" % "6.25.0":

import com.twitter.{util => twitter} 
import scala.concurrent.{ExecutionContext, Promise, Future} 
import scala.util.{Failure, Success, Try} 
import language.implicitConversions 

object TwitterConverters { 
    implicit def scalaToTwitterTry[T](t: Try[T]): twitter.Try[T] = t match { 
    case Success(r) => twitter.Return(r) 
    case Failure(ex) => twitter.Throw(ex) 
    } 

    implicit def twitterToScalaTry[T](t: twitter.Try[T]): Try[T] = t match { 
    case twitter.Return(r) => Success(r) 
    case twitter.Throw(ex) => Failure(ex) 
    } 

    implicit def scalaToTwitterFuture[T](f: Future[T])(implicit ec: ExecutionContext): twitter.Future[T] = { 
    val promise = twitter.Promise[T]() 
    f.onComplete(promise update _) 
    promise 
    } 

    implicit def twitterToScalaFuture[T](f: twitter.Future[T]): Future[T] = { 
    val promise = Promise[T]() 
    f.respond(promise complete _) 
    promise.future 
    } 
} 

Answer 2

Możliwe jest również do korzystania z serwisu Twitter bijections Biblioteka: https://github.com/twitter/bijection

Mianowicie com.twitter.bijection.twitter_util.UtilBijections (https://github.com/twitter/bijection/blob/develop/bijection-util/src/main/scala/com/twitter/bijection/twitter_util/UtilBijections.scala)

Ta biblioteka obsługuje ważne szczegóły, na przykład, jeśli konwertuje obiekt do przodu i do tyłu, po prostu rozpakowuje oryginalny obiekt.

Answer 3

Oto przykład przy użyciu bijection bibliotekę Twitterze:

import scala.concurrent.{Future => ScalaFuture} 
import com.twitter.util.{Future => TwitterFuture} 

// extend values by adding the conversion method "as" 
import com.twitter.bijection.Conversion.asMethod 

// pull in various implicit converters that "as" expects, 
// including twitter2ScalaFuture: 
import com.twitter.bijection.twitter_util.UtilBijections._ 

def doSomething: ScalaFuture[T] = { 
    val response: TwitterFuture[T] = ??? 
    response.as[ScalaFuture[T]] 
}