flags
in https://github.com/fehmicansaglam/tepkin/blob/master/tepkin/src/main/scala/net/fehmicansaglam/tepkin/protocol/message/Reply.scala but are not parsed (but maybe I am in the wrong version of the wire protocol).
MongoCursors
(it should never complete normally). if (cursorID == 0 && tailable) onError(new DeadCursorException())
. The user could then decide to use a proper failure policy (restart or fail the whole stream, or switch to another source or whatever)
MongoCursor
actor)
document.getAs[Int]("age").value shouldBe 18
document.getAs[Double]("details.salary").value shouldBe 455.5
document.getAs[String]("details.personal.foo").value shouldBe "bar"
document.getAsList[List[_]]("details.inventory").value shouldBe List("a", 3.5, 1L, true)
val details = document.getAs[BsonDocument]("details").get
details.getAs[Double]("salary").value shouldBe 455.5
val personal = document.getAs[BsonDocument]("details.personal").get
personal.getAs[String]("foo").value shouldBe "bar"
}