在阿卡演员

Question

我负责的第三方库，它为我提供了异步方法包装的异步调用的过程是这样的：

def doSomething1(input:String, callback:String => Any) 
def doSomething2(input:Double, callback:String => Any) 

库运行在某个线程的东西它创建。

我想围绕一个演员，所以我可以ask它为垃圾，但我不知道如何获得promise访问，以便我可以满足要求。

简易方法：

class Wrapper extends Actor { 
    def receive { 
    case s:String => doSomething1(s, sender ! _) 
    case d:Double => doSomething2(d, sender ! _) 
    } 
} 

val wrapper = system.actorOf(Props[Wrapper], "wrapper") 

然后ask它的结果：

(wrapper ? "hello").mapTo[String].foreach(println) 
(wrapper ? 123.456).mapTo[String].foreach(println) 

但结果不会回来，大概是因为回调不从演员也ask版的到来。

有没有办法获得promise所以回拨可以success呢？

Answer 1

请注意，我没有测试过这一点，但是这是你在找什么？：

class Wrapper extends Actor { 
    def receive = { 
    case s : String => 
     val response = Promise[String]() 
     val originator = sender 
     doSomething1(s, response.success _) 
     response.future.foreach(originator ! _) 
    case d : Double => 
     val response = Promise[Double]() 
     val originator = sender 
     doSomething2(d, response.success _) 
     response.future.foreach(originator ! _) 
    } 
}