जारी रखें जब एक Future.failed (नया अपवाद ("")) स्कैला

Question

में वापस कर दिया गया है यदि भविष्य में एक असफल अपवाद लौटाता है तो मैं कैसे संभाल सकता हूं?

परिदृश्य है कि मेरे कोड कॉल getValue(), verifyValue() लिए परिणाम नक्शे और उसके बाद मैं इस मामले में जहां getValue का परिणाम() Future.failed(new Exception("message")) है संभाल करने में सक्षम होना चाहते है। हालांकि जब मैं इसे चलाता हूं, तो getValue() का नतीजा एक असफल भविष्य है, तो यह इसे संभालने के बजाय अपवाद फेंकता है।

क्या किसी के पास कोई सुझाव है कि मैं यह कैसे करूं?

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) 
    } 
} 

अद्यतन: मुझे लगता है मैं मूल प्रश्न के साथ इस स्पष्ट कर दिया नहीं लगता है, लेकिन कारण है कि मैं मूल्य flatmap है जिन्हें मैंने स्पष्ट रूप में वायदा में से किसी के लिए प्रतीक्षा करने के लिए नहीं करना चाहते हैं मेरा कोड, और इसलिए मैं मूल्य को हल करने के लिए Future.onComplete {} का उपयोग नहीं करना चाहता हूं।

अद्यतन 2: एक और चीज जो स्पष्ट नहीं हो सकती है कि अगर यह अपवाद फेंकता है, तो मैं एक और विधि कॉल करना चाहता हूं। मैं नहीं चाहता कि यह केवल अपवाद को संभालने के लिए है, यह अपवाद लॉग करने जा रहा है और फिर दूसरी विधि को कॉल करें जिसका रिटर्न वैल्यू getValue() के समान प्रकार का है।

Answer 1

क्या मैं कर रहा Future.fallbackTo() विधि का उपयोग कर रहा समाप्त हो गया के भविष्य लेता है।

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

पहले getValue() से भविष्य में विफल रहता है, तो यह method1() कॉल करेंगे। यदि यह भी विफल रहता है, तो यह method2() इत्यादि को कॉल करेगा। यदि कोई विधि सफल हो जाती है, तो वह उस मान को वापस कर देगी। यदि कोई भी विधि सफल नहीं होती है, तो यह असफल भविष्य को getValue() से वापस कर देगा।

यह समाधान आदर्श नहीं है, क्योंकि अगर सभी प्रयास विफल हो जाते हैं तो मैं सभी चार अपवादों को फेंकना चाहता हूं, लेकिन कम से कम मुझे getValue() विधि को फिर से प्रयास करने की अनुमति मिलती है।

Answer 2

import scala.util.{Success, Failure} 

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

आप) अपने विधि (में onComplete उपयोग कर सकते हैं, अन्य विकल्पों के लिए नीचे दिए गए लिंक के रूप में अच्छी तरह से देखें:

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

Answer 3

उपयोग recover या recoverWith

की वसूली या recoverWith जब भविष्य कहा जाता है एक अपवाद के साथ विफल रहता है। पुनर्प्राप्ति ब्लॉक में आप वैकल्पिक मूल्य दे सकते हैं।

recoverWithrecover के विपरीत कुछ

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