MongoのScalaの非同期クライアントは、このコードを使用して新しいScalaの非同期ドライバとアップサートしようとして

Question

を書いていないが、DBは、これは何回も呼ばれているにもかかわらず、作成されることは決してありません：

override def insertOrUpdateOne(user: UserNew): Future[Unit] = { 
    users.replaceOne(equal("_id", user._id), user) 
    .toFuture 
    .map(_ =>()) 
} 

のmongoクライアントは罰金作成し、コレクションを作成します実際にはdbは作成されません（最初の書き込みで発生するはずです）。私は、casbahを使用し、同期的に動作している他のコードを持っています。

usersは、私からの構文的な砂糖のないモンゴーのコレクションです。

toFutureサブスクリプション（書き込みをトリガーする必要がありますか？）が、まだ動作しません。私はいくつかのコレクションをカスバと混同しています.1つは非同期クライアントに、もう1つは非同期で動作します。

アイデア？

Answer 1

それは、ドキュメント内

override def insertOrUpdateOne(user: UserNew): Future[Unit] = { 
    users.replaceOne(equal("_id", user._id), user, UpdateOptions().upsert(true)) 
    .toFuture 
    .map(_ =>()) 
} 

何もないはずですが、私は、コードを読んだとき、私はfalseにアップサートそれをデフォルト設定を参照してください。

これにより、Observableとsubscribeのものとコールバックの設定をすべて無視できます。 Scalaの慣用句で結果を処理するだけsomeFuture.map()これは、UsersDao非Mongo固有のコードをインタフェースにします。これにより、UsersDaoImplのすべてのコードでMongo固有のものを扱うことができ、Implを注入できるようになり、実行時の選択を約Implにすることができます。 Mongoは、依存コードを気にすることなく、あるいはImplについて知っていなくても置き換えることができます。