Wie async Mongo Abfrage zu testen?

Question

Gibt es eine gute Strategie, einen asynchronen insert zu einer mongodb Sammlung mit MongoDB Scala-Treiber zu testen 1.1:

driver.myCollection.insertOne(doc).subscribe(new Observer[Completed] { 

     override def onNext(result: Completed): Unit = /* do something */ 

     override def onComplete(): Unit = /* do something */ 

     override def onError(e: Throwable): Unit = /* do something */ 
    }) 

Alle Mock in einem Test, um sie auszuführen vorgeschlagen? Das Observable verspotten? Und im Falle eines Integrationstests?

Answer 1

Eine mögliche Lösung ist insertOne aufzurufen und drehen den Observable[T] in eine Future[T] und verwenden Await.result synchron auf ihn zu blockieren. Diese Umwandlung wird in der ScalaObservable[T] impliziten Klasse definiert:

import org.mongodb.scala.ObservableImplicits._ 

val future = driver 
       .myCollection 
       .insertOne(docs) 
       .toFuture() 

Await.result(future, Duration(3000, MILLISECONDS)) 

Hinweis dies erfordert den Import von ObservableImplicits.