呼叫阻塞

Question

裹异步代码，我在MongoDB中插入一条记录：

val observable: Observable[Completed] = collection.insertOne(doc) 

observable.subscribe(new Observer[Completed] { 
    override def onNext(result: Completed): Unit = { println("Inserted"); } 
    override def onError(e: Throwable): Unit = { println(" \n\nFailed " + e + "\n\n"); fail() } 
    override def onComplete(): Unit = { println("Completed"); } 
}) 

即使onError调用回调函数的测试通过。这是因为insertOne是异步方法，并且在调用onError之前完成测试。我想将insertOne方法封装成阻塞调用，因此subscribe不会被调用，直到observable值被设置。

有没有一种惯用的方法来实现这一点是在斯卡拉？

Answer 1

同步阻止异步操作的最简单方法是在Future上使用Await.result。由于MongoCollection.insertOne返回Observable[Complete]，你可以在上面使用隐ScalaObservable.toFuture：

val observable = collection.insertOne(doc) 
Await.result(observable.toFuture, Duration.Inf) 

observable.subscribe(new Observer[Completed] { 
    override def onNext(result: Completed): Unit = { println("Inserted"); } 
    override def onError(e: Throwable): Unit = { println(" \n\nFailed " + e + "\n\n"); fail() } 
    override def onComplete(): Unit = { println("Completed"); } 
})