For example, I had an observable print something when there is an error (onError method) while inserting something with the db shutted down, but the method is never called. Shouldn’t an exception be thrown at the time I get a MongoConnection? Or the onError method called when I send an operation to a shutted down db?
Hi Victor,
You can see examples of handling observables on MongoDB Scala Driver: observables
For example :
val insertObservable: Observable[Completed] = collection.insertOne(document)
insertObservable.subscribe(new Observer[Completed] {
override def onNext(result: Completed): Unit = println(s"onNext: $result")
override def onError(e: Throwable): Unit = println(s"onError: $e")
override def onComplete(): Unit = println("onComplete")
})
If you still have further questions, could you please provide:
onError
) Regards,
Wan