Scala valore restituito da onComplete

Question

Come posso strutturare onComplete a Scala di agire in questo modo:

Fig 1

{ 
    var x; 
    if(result.isFailure){ 
    x = foo() // foo is a future 
    } 

    if(result.isSuccess){ 
    x = 5 
    } 
    bar(x) 
} 

ho pensato che avrei potuto fare in questo modo:.

Fig. 2

var x = foo onComplete { 
    case Success(x) => 5 
    case Failure(t) => foo() //foo is a future 
} 
bar(x) 

Ma onComplete, onFailure e onSuccess tutti hanno Unit come loro tipo di ritorno,

onComplete[U](f: (Try[T]) ⇒ U)(implicit executor: ExecutionContext): Unit 
onSuccess[U](pf: PartialFunction[T, U])(implicit executor: ExecutionContext): Unit 
onFailure[U](pf: PartialFunction[Throwable, U])(implicit executor: ExecutionContext): Unit 

Come posso ottenere qualcosa di figura in due senza utilizzare una var?

Answer 1

Si sconsiglia di bloccare il thread corrente in attesa di un risultato da un futuro. Invece, dovresti chiamare la funzione bar() sull'elaborazione dei risultati del futuro result.

result map {r => 
    5 
} recover { 
    case _ => foo() 
} map {r => 
    bar(r) 
} 

Answer 2

È possibile raggiungere il tuo obiettivo con

val x: Future[Int] = foo.map(x => 5).recover{case f => foo()} 
// do some more work with your future 
x.map(bar(_)) 

Supponendo che foo: Future[_] e foo(): Int.