Tiếp tục khi một Future.failed (ngoại lệ mới ("")) được trả lại trong Scala

Question

Làm cách nào để xử lý nếu một tương lai trả về ngoại lệ không thành công?

Kịch bản là mã của tôi gọi getValue(), ánh xạ kết quả đến verifyValue() và sau đó tôi muốn có thể xử lý trường hợp kết quả của getValue() là Future.failed(new Exception("message")). Tuy nhiên khi tôi chạy điều này, nếu kết quả của getValue() là một tương lai không thành công nó chỉ ném ngoại lệ hơn là xử lý nó.

Có ai có bất kỳ đề xuất nào về cách tôi thực hiện việc này không?

def method(): Future[JsObject] = { 
    getValue().flatMap(verifyValue(_)) 
} 

def getValue(): Future[JsObject] = { 
    try { 
     value1 <- getValue1() 
     value2 <- getValue2(value1) 
    } yield { 
     value2 
    } 
} 

def verifyValue(result: Any): Future[JsObject] = { 
    result match { 
    case e: Exception => 
     getValue() 
    case json: JsObject => Future.successful(json) 
    } 
} 

Cập nhật: Tôi không nghĩ rằng tôi thực hiện điều này rõ ràng với câu hỏi ban đầu, nhưng lý do tại sao tôi flatMap giá trị là tôi không muốn dứt khoát phải đợi cho bất kỳ thị trường kỳ hạn trong mã của tôi, và do đó tôi không muốn sử dụng Future.onComplete {} để giải quyết giá trị.

Cập nhật 2: Một điều khác có thể không rõ ràng là nếu nó ném một ngoại lệ, tôi muốn gọi phương thức khác. Tôi không muốn nó chỉ xử lý ngoại lệ, nó sẽ ghi lại ngoại lệ và sau đó gọi một phương thức khác có giá trị trả về bằng cùng kiểu với getValue().

Answer 1

Những gì tôi đã kết thúc làm được bằng cách sử dụng phương pháp Future.fallbackTo().

def method(): Future[JsObject] = { 
    getValue().fallbackTo(method1()).fallbackTo(method2()).fallbackTo(method3()) 
} 

Nếu tương lai từ getValue() đầu tiên không thành công, nó sẽ gọi method1(). Nếu điều đó cũng không thành công, nó sẽ gọi method2() vv Nếu một trong các phương thức thành công, nó sẽ trả về giá trị đó. Nếu không có phương thức nào thành công, nó sẽ trả về tương lai không thành công từ getValue().

Giải pháp này không lý tưởng, vì tôi muốn bao gồm cả bốn ngoại lệ nếu tất cả các lần thử thất bại, nhưng ít nhất nó cho phép tôi thử lại phương thức getValue().

Answer 2

import scala.util.{Success, Failure} 

f.onComplete { 
    case Success(value) => // do sth with value 
    case Failure(error) => // do sth with error 
} 

Bạn có thể sử dụng onComplete trong phương pháp của bạn(), xem link bên dưới cho các tùy chọn khác như:

http://www.scala-lang.org/api/2.9.3/scala/concurrent/Future.html

Answer 3

Sử dụng recover hay recoverWith

phục hồi hoặc recoverWith được gọi là khi tương lai thất bại với một ngoại lệ. Trong khối khôi phục, bạn có thể đưa ra giá trị thay thế.

recoverWith không giống như recover mất tương lai của một cái gì đó

getValue().recover { case th => 
    //based on the exception type do something here 
    defaultValue //returning some default value on failure 
}