Este código selecciona todos los elementos de una colección mongodb:

 import scala.collection.immutable.IndexedSeq import org.mongodb.scala._ import org.mongodb.scala.model.Aggregates._ import org.mongodb.scala.model.Filters._ import org.mongodb.scala.model.Projections._ import org.mongodb.scala.model.Sorts._ import org.mongodb.scala.model.Updates._ import org.mongodb.scala.model._ import org.mongodb.scala.bson._ object Main extends App { //http://mongodb.github.io/mongo-scala-driver/1.0/scaladoc/index.html#org.mongodb.scala.bson.collection.immutable.Document // Use a Connection String val mongoClient: MongoClient = MongoClient("mongodb://mymongo.com:27017") // get handle to "mydb" database val database: MongoDatabase = mongoClient.getDatabase("mydb") // get a handle to the "test" collection val collection: MongoCollection[Document] = database.getCollection("mycol") val observable: FindObservable[Document] = collection.find(); observable.subscribe ( new Observer[Document] { override def onNext(result: Document): Unit = { println(result("question")+"->"+result("answer")) } override def onError(e: Throwable): Unit = println("Failed" + e.getMessage) override def onComplete(): Unit = println("Completed") }) Thread.sleep(5000) }

La salida de este código es:

 BsonString{value='map1'}->BsonString{value='value1'} BsonString{value='map2'}->BsonString{value='value2'} BsonString{value='map3'}->BsonString{value='value3'}

Estoy esperando :

 map1->value1 map2->value2 map3->value3

Estoy usando Thread.sleep (5000) como observable.subscribe no bloquea y necesito mantener vivo el hilo principal para evitar que el hilo principal salga antes de que se complete el observable.subscribe.

Al leer la API para BsonString http://api.mongodb.com/java/current/org/bson/BsonString.html , ¿no parece haber un método para acceder al valor?