BSONCollection.findAndRemove () нельзя вызвать с помощью flatmap - PullRequest
Новая
       17

BSONCollection.findAndRemove () нельзя вызвать с помощью flatmap

0 голосов
/ 12 февраля 2019

Тип коллекции ReactiveMongo предоставляет метод findAndRemove , который можно использовать для удаления одного документа из коллекции на основе критериев в запросе.Возвращает будущее, описывающее результат операции удаления.Вызов flatMap () для Future of the Future приводит к довольно загадочному сообщению об ошибке: 

type mismatch;
 found   : reactivemongo.api.collections.bson.BSONCollection => scala.concurrent.Future[x$5.BatchCommands.FindAndModifyCommand.FindAndModifyResult] forSome { val x$5: reactivemongo.api.collections.bson.BSONCollection }
 required: reactivemongo.api.collections.bson.BSONCollection => scala.concurrent.Future[S]

Я предполагаю, что это тип результата внутреннего класса, который я не могу использовать напрямую.Я не могу понять, что я должен делать здесь, чтобы использовать это.Весь список выглядит так: 

import reactivemongo.api.collections.bson.BSONCollection
import reactivemongo.api.{Cursor, DB, MongoConnection, MongoDriver}
import reactivemongo.bson.{BSONDocument, BSONDocumentReader, BSONDocumentWriter, Macros}

import scala.concurrent.ExecutionContext.Implicits.global
import scala.concurrent.{Await, Future}
import scala.concurrent.duration._

object ReactiveMongoTest extends App {

  case class Element(symbol: String, atomicNumber: Long, atomicMass: Double)
  implicit val elementReader: BSONDocumentReader[Element] = Macros.reader[Element]
  implicit val elementWriter: BSONDocumentWriter[Element] = Macros.writer[Element]

  val elements = Seq(
    Element("Fe", 26, 55.845),
    Element("Co", 27, 58.933),
    Element("Ni", 28, 58.693)
  )

  def await[T](future: => Future[T]): T = Await.result(future, Duration.Inf)


  lazy val driver: MongoDriver = MongoDriver()
  lazy val conn: MongoConnection = driver.connection(Seq("localhost"))
  def testDb: Future[DB] = conn.database("testDb")
  def testColl: Future[BSONCollection] = testDb.map(_.collection("testColl"))

  def insert = testColl.flatMap(_.insert(ordered = true).many(elements))

  def list = testColl.flatMap {
    _.find(BSONDocument(), projection = Option.empty)
      .cursor[Element]()
      .collect[Seq](Int.MaxValue, Cursor.FailOnError[Seq[Element]]())
  }

  def remove = testColl.flatMap(_.findAndRemove(BSONDocument("atomicNumber" -> 26)))

  println(await(insert))

  await(list).foreach(x => println(s"listing -> ${x}"))

//  println(await(remove))

  println("After removing!")
  await(list).foreach(x => println(s"listing -> ${x}"))

  sys.exit()

}

Сообщение об ошибке: 

Error:(37, 48) type mismatch;
 found   : reactivemongo.api.collections.bson.BSONCollection => scala.concurrent.Future[x$4.BatchCommands.FindAndModifyCommand.FindAndModifyResult] forSome { val x$4: reactivemongo.api.collections.bson.BSONCollection }
 required: reactivemongo.api.collections.bson.BSONCollection => scala.concurrent.Future[S]
  def remove = testColl.flatMap(_.findAndRemove(BSONDocument("atomicNumber" -> 26)))

Обновление 1: Работает карта вызова: 

def remove = testColl.map(_.findAndRemove(BSONDocument("atomicNumber" -> 26)))
println(await(await(remove)))

1 Ответ

0 голосов
/ 12 февраля 2019

ReactiveMongo слишком умный со многими этими внутренними классами дел и т. Д., И каждый раз, когда мне приходилось его использовать, я сталкиваюсь с такими странными проблемами, как эта.Вы можете принудительно скомпилировать его, предоставив аннотацию типа, которая фиксирует область действия экзистенциала: 

scala> type FAMResult =
     |   c.BatchCommands.FindAndModifyCommand.FindAndModifyResult forSome {
     |     val c: BSONCollection
     |   }
defined type alias FAMResult

scala> def remove =
     |   testColl.flatMap[FAMResult](_.findAndRemove(BSONDocument("atomicNumber" -> 26)))
remove: scala.concurrent.Future[FAMResult]

Если вы не заботитесь о результатах команды удаления, тем не менее, это, вероятно, не идеально.Лучшим подходом является отображение в Future[<blah blah blah>.FindAndModifyResult] внутри * flatMap, чтобы вы получили более полезный тип: 

scala> def remove = testColl.flatMap(
     |   _.findAndRemove(BSONDocument("atomicNumber" -> 26)).map(_.value)
     | )
remove: scala.concurrent.Future[Option[reactivemongo.bson.BSONDocument]]

Вы также можете просто .map(_ => ()), есливы на самом деле не заботитесь о результате, .map(_.result[Element]), если хотите, чтобы результат был декодирован и т. д.

...