Scala Rückgabewert von onComplete

Question

Wie kann ich onComplete in Scala Struktur auf diese Weise handeln:

Abb 1

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

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

Ich dachte, ich es auf diese Weise tun könnte.

Abb. 2

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

Aber onComplete, onFailure und onSuccess alle haben Unit als ihre Rückgabetyp,

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 

Wie kann ich etwas erreichen, Figur zwei-ish ohne eine Var zu verwenden?

Answer 1

Es wird davon abgeraten, den aktuellen Thread zu blockieren, indem ein Ergebnis aus einer Zukunft erwartet wird. Stattdessen sollten Sie die Funktion bar() aufrufen, um die Ergebnisse der result Zukunft zu verarbeiten.

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

Answer 2

Sie können Ihr Ziel mit

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

Unter der Annahme, dass foo: Future[_] und foo(): Int erreichen.