मोंगोडब स्कैला ड्राइवर - एक दस्तावेज़ को पुनः प्राप्त करने में असमर्थ

ठीक है, मैं खुद को दोष देता हूं (और ड्राइवर के रहस्यवादी दस्तावेज)

यह ड्राइवर एसिंक्रोनस है, इसलिए हमें बस इसके पूरा होने की प्रतीक्षा करनी है...तो इसका उपयोग करने के लिए (मिला यहां ) जो वास्तव में ड्राइवर के बिना दस्तावेज़ीकरण में उपयोग किया जाता है

implicit class DocumentObservable[C](val observable: Observable[Document]) extends ImplicitObservable[Document] {
   override val converter: (Document) => String = (doc) => doc.toJson
}

implicit class GenericObservable[C](val observable: Observable[C]) extends ImplicitObservable[C] {
   override val converter: (C) => String = (doc) => doc.toString
}

trait ImplicitObservable[C] {
  val observable: Observable[C]
  val converter: (C) => String

  def results(): Seq[C] = Await.result(observable.toFuture(), Duration(10, TimeUnit.SECONDS))
  def headResult() = Await.result(observable.head(), Duration(10, TimeUnit.SECONDS))
  def printResults(initial: String = ""): Unit = {
    if (initial.length > 0) print(initial)
    results().foreach(res => println(converter(res)))
  }
  def printHeadResult(initial: String = ""): Unit = println(s"${initial}${converter(headResult())}")
}

और इस तरह से पुनः प्राप्त करना बदलना:

def retrieveDocument(id: Int, collectionName: String, databaseName: String, url: String): Option[Document] = {
var res: Option[Document] = None
getMongoCollectionImmutable(collectionName, databaseName, url)
  .find(Filters.equal("_id", id))
  .limit(1).results().foreach({ x => res = Some(x) })
res

}

यह मेरी समस्या का समाधान करता है।