Scala tương lai với bộ lọc trong cho sự hiểu biết

Question

Trong ví dụ dưới đây tôi nhận được ngoại lệ java.util.NoSuchElementException: Future.filter predicate is not satisfied

Tôi muốn có kết quả Future(Test2) khi kiểm tra if(i == 2) thất bại. Làm thế nào để xử lý bộ lọc/nếu trong một hiểu cho rằng giao dịch với tương lai soạn?

Dưới đây là một ví dụ đơn giản hóa hoạt động trong REPAL 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 

Answer 1

Trong for-comprehension của bạn, bạn đang lọc theo i == 2. Bởi vì giá trị của f1 không phải là hai, nó sẽ không mang lại một số Success mà thay vào đó là Failure. Vị từ của bộ lọc không hài lòng, vì thông điệp errror của bạn cho bạn biết. Tuy nhiên, f2.recover trả về một Future mới. Giá trị của f2 không được điều khiển. Nó vẫn lưu trữ Failure. Đó là lý do bạn nhận được thông báo lỗi khi bạn gọi f2.value.

Cách thay thế duy nhất tôi có thể nghĩ là sử dụng else trong số for-comprehension như được hiển thị here.

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

Điều này sẽ trả về Some(Success(Test2)) làm f3.value của bạn.

Answer 2

Dĩ nhiên tôi đã tìm ra một giải pháp bản thân mình. Có lẽ có giải pháp tốt hơn, thành ngữ hơn?

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 

Answer 3

Đây là giải pháp thành ngữ hơn, theo ý kiến ​​của tôi. Hàm biến vị ngữ này tạo ra một số Future[Unit] hoặc một tương lai không thành công có chứa ngoại lệ của bạn. Ví dụ của bạn, điều này sẽ dẫn đến hoặc là Success("Test1") hoặc Failure(Exception("Test2")). Điều này hơi khác với "Test1" và "Test2", nhưng tôi thấy cú pháp này hữu ích hơn.

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

Bạn sử dụng nó như thế này:

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