が、私は将来を返すレポメソッドを持っているのScala

Question

でみてくださいでラップ：

def insert(newUser: User): Future[User] 

この方法では、様々な理由で失敗することができ、しかし、私はこれらの理由の1をキャッチできるようにしたいです他の人を転覆させる。 私は単に結果として試してみてください

Try(userRepository.insert(usr)) match { 
     case Success(newUserFuture) => newUserFuture 

     case Failure(e) if e.getCause.getMessage.contains("duplicate key") => { 
     logger.warn(e.getMessage) 
     throw DuplicateEntityException("duplicate user record") 
     } 

     case Failure(e) => { 
     logger.error(e.getMessage) 
     throw e 
     } 
    } 

とのコールをラップしていた場合、私はTry[Future[User]]を取得していますが、この状況では、どちらの障害の未来が正常に作成されて以来、発生します。 この時点で、私はそれに対処する方法がわかりません。理想的には、Future[Either[String, User]]（またはそれに類するもの）を手に入れたいです。

この状況にどう対処すればよいですか、まったく間違った方向に向いていますか？

EDIT以下の推奨 このような解決策 私が試した何か：私はあなたのコードをクリーンアップあなたのアプローチを逆にし、ケースにはガードを使用することができると思う

userRepository.insert(usr).map(newUser => Right(newUser)) recoverWith { 
     case e: PSQLException if e.getMessage.contains("duplicate key") => 
     Future.successful(Left("duplicate user record")) 
    } 

Answer 1

Futureが例外を処理します。将来のコードをTryで囲む必要はありません。

FutureTryのジョブも同様です。

このコード行は必要ありません

Try(userRepository.insert(usr)) 

私はあなたの挿入方法は、上記の方法では、この

def insert(newUser: User): Future[User] = Future { doSomeDBCall() } 

のようなものであると思います。 doSomeDBCall()が失敗した場合。この例外は将来安全にキャッチされ、Failure(exception)という発信者に配信されます。したがって、FutureをTry

で捕捉する必要はありません。特定の例外をキャッチし、他の例外をスローする（他のものを伝播する）必要はありません。あなたはrecoverWithを使用して例外を処理し、あなたに興味を持っていない例外を伝播させることができます。

以下のコードSQLExceptionで

が処理され、他の例外は、呼び出し側に伝播されます。

userRepository.insert(usr).recoverWith { 
case ex: SQLException => Future.successful(defaultValue) 
case ex => Future.failed(ex) 
} 

Answer 2

少し。まず、userRepository.insert(usr)にはFuture[Try[User]]が返されます。

userRepository.insert(user).map { 
    case Success(insertedUser) => Right(insertedUser) 
    case Failure(ex) if ex.getCause.getMessage.contains("duplicate key") => throw DuplicateEntityException("duplicate user record") 
    case Failure(ex) => throw ex 
} 

この結果は、ユーザーまたは契約で他に何かをするか（http://docs.scala-lang.org/overviews/core/futures.htmlを参照）へのコールバックを添付することができますFuture[User]次のようになります。そして、このように使用することができます

def insert(user: User): Future[Try[User]] 

例外はある。

Answer 3

はそのような何かしてみてください：残念ながら

def checkOperations[A](operations: List[Try[A]]): Future[List[A]] = { 
    Future { 
     if (!operations.filter(_.isFailure).isEmpty) { 
     // there were some error 

     } else { 
     // all operations are ok 
    } 
}