scullxbones/akka-persistence-mongo

Do not use AkkaStreamCursor when not required

Closed this issue 5 years ago · 0 comments

cchantep commented 5 years ago

akka-persistence-mongo/rxmongo/src/main/scala/akka/contrib/persistence/mongodb/RxMongoJournaller.scala

Line 84 in 90ad042

    
           collection.flatMap(_.insert[BSONDocument](ordered = true, writeConcern).many(collected).map(_ => batch))

http://reactivemongo.org/releases/0.1x/api/reactivemongo/api/collections/InsertOps$InsertBuilder.html#many[T](documents:Iterable[T])(implicitec:scala.concurrent.ExecutionContext,implicitwriter:InsertOps.this.pack.Writer[T]):scala.concurrent.Future[reactivemongo.api.commands.MultiBulkWriteResult]