Scala Avenir avec filtre pour la compréhension

Dans l'exemple ci-dessous j'ai accès à l'exception java.util.NoSuchElementException: Future.filter predicate is not satisfied

Je veux avoir le résultat Future( Test2 ), quand la case if( i == 2 ) échoue. Comment dois-je traiter le filtre/si dans une compréhension qui traite de la composition des contrats à terme?

Ci-dessous est un exemple simplifié qui travaille à la Scala REPL.

Code:

import scala.concurrent.Future
import scala.util.{ Try, Success, Failure }
import scala.concurrent.ExecutionContext.Implicits.global

val f1 = Future( 1 )
val f2 = for {
  i <- f1
  if( i == 2 )
} yield "Test1"
f2.recover{ case _ => "Test2" }
f2.value
InformationsquelleAutor Magnus | 2013-07-25
  1. 11

    Dans votre for-comprehension, vous êtes le filtrage par i == 2. Parce que la valeur de f1 n'est pas deux, il ne donnera pas un Success mais plutôt un Failure. Le prédicat de filtre n'est pas satisfait, que votre erreur message vous indique. Cependant, f2.recover retourne une nouvelle Future. La valeur de f2 n'est pas manipulé. Il stocke toujours les Failure. C'est la raison pour laquelle vous obtenez le message d'erreur lorsque vous appelez f2.value.

    La seule alternative que je peux penser serait à l'aide d'un else dans votre for-comprehension comme le montre ici.

    val f2 = for ( i <- f1) yield {
  if (i == 2) "Test1"
  else "Test2"
}
f2.value

    Ce sera le retour de Some(Success(Test2)) que votre f3.value n'.

    • Toutefois, si f2 échoue en raison de "i <- f1" à défaut, le résultat ne sera pas "Test2", mais encore un Échec.
    InformationsquelleAutor tgr
  2. 29

    C'est un plus idiomatiques solution, à mon avis. Cette fonction de prédicat crée une Future[Unit] ou de l'échec d'un avenir contenant vos exception. Pour ton exemple, cela aurait pour conséquence soit une Success("Test1") ou un Failure(Exception("Test2")). C'est un peu différent de "Test1" et "Test2", mais je trouve cette syntaxe pour être plus utile.

    def predicate(condition: Boolean)(fail: Exception): Future[Unit] = 
    if (condition) Future( () ) else Future.failed(fail)

    Vous l'utiliser comme ceci:

    val f2 = for {
  i <- f1
  _ <- predicate( i == 2 )(new Exception("Test2"))
  j <- f3  //f3 will only run if the predicate is true
} yield "Test1"
    • C'était des conseils très utiles. Merci!
    • Beaucoup plus clair, merci!
    InformationsquelleAutor pkinsky
  3. 8

    Bien sûr, j'ai pensé à une solution moi-même. Peut-être il y a de mieux, de plus idiomatiques, des solutions?

    import scala.concurrent.Future
import scala.util.{ Try, Success, Failure }
import scala.concurrent.ExecutionContext.Implicits.global

val f1 = Future( 1 )
val f2 = for {
  i <- f1
  if( i == 2 )
} yield "Test1"
val f3 = f2.recover{ case _ => "Test2"  }
//OR val f3 = f2.fallbackTo( Future( "Test2" ) )
f3.value
    • Il est mentionné dans la documentation ainsi: docs.scala-lang.org/overviews/core/... pas lorsque je de prendre un second regard.
    • Je pense que l'utilisation recover ici est d'accord. Si vous voulez récupérer de n'appliquer le prédicat de filtre en fonction de l'exception, alors vous devez changer le case _ à case ex:NoSuchElementException où NoSuchElementException vient de java.util.
    • Jürgen: C'est un six mois question, le code ci-dessus est un exemple de prise de RÉPLICATION de session, donc il est orienté vers la clarté. Vous êtes en commentant que vous pouvez mettre des parenthèses autour de déclarations en Scala? Ne pas voir ce que votre contribution est ici.
    InformationsquelleAutor Magnus
  4. 0

    J'ai aimé @pkinsky l'idée, et fait un peu d'amélioration. J'ai laissé tomber le code pour créer Exception objet comme ceci:

    val f2 = for {
  i <- f1
  _ <- shouldTrue( i == 2 )
  j <- f3  //f3 will only run if the predicate is true
} yield "Test1"

    shouldTrue fonction est implémentée à l'aide de lihaoyi de code source bibliothèque:

    def shouldTrue(condition: sourcecode.Text[Boolean])(implicit enclosing: sourcecode.Enclosing, file: sourcecode.File, line: sourcecode.Line): Future[Unit] =
  if (condition.value) Future.successful( () ) else Future.failed(new Exception(s"${condition.source} returns false\n\tat ${file.value}:${line.value}"))

    Ensuite, il génère automatiquement des plus significatives de message d'exception:

    java.lang.Exception: i == 2 returns false
    at \path\to\example.scala:17
    InformationsquelleAutor pocorall