स्काला भविष्य में समझ

Question

उदाहरण में के लिए नीचे मैं अपवाद java.util.NoSuchElementException: Future.filter predicate is not satisfied

मिल रहा जब जांच if(i == 2) विफल रहता परिणाम Future(Test2) करना चाहते हैं फिल्टर के साथ। मैं फ़िल्टर को कैसे संभाल सकता/सकती हूं अगर समझने के लिए वायदा वायदा से संबंधित है?

नीचे एक सरलीकृत उदाहरण है जो स्कैला आरईपीएल में काम करता है।

कोड:

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

अपने for-comprehension में, आप i == 2 द्वारा फ़िल्टर कर रहे हैं। चूंकि f1 का मान दो नहीं है, इसलिए यह Success नहीं मिलेगा बल्कि इसके बजाय Failure होगा। फ़िल्टर का पूर्वानुमान संतुष्ट नहीं है, क्योंकि आपका त्रुटि संदेश आपको बताता है। हालांकि, f2.recover एक नया Future देता है। f2 का मान छेड़छाड़ नहीं किया गया है। यह अभी भी Failure स्टोर करता है। जब आप f2.value पर कॉल करते हैं तो आपको त्रुटि संदेश मिलता है।

एकमात्र विकल्प जिसे मैं सोच सकता हूं else आपके for-comprehension में दिखाया जाएगा जैसा कि here दिखाया गया है।

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

इस रूप में अपने f3.value करता Some(Success(Test2)) वापस आ जाएगी।

Answer 2

बेशक मैं बाहर एक समाधान अपने आप लगा। शायद बेहतर, अधिक मूर्खतापूर्ण, समाधान हैं?

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

यह मेरी राय में एक और मूर्खतापूर्ण समाधान है। यह अनुमानित फ़ंक्शन या तो Future[Unit] या आपके अपवाद वाले असफल भविष्य को बनाता है। आपके उदाहरण के लिए, इसका परिणाम Success("Test1") या Failure(Exception("Test2")) होगा। यह "टेस्ट 1" और "टेस्ट 2" से थोड़ा अलग है, लेकिन मुझे यह वाक्यविन्यास अधिक उपयोगी होने लगता है।

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

आप इस तरह इसका इस्तेमाल:

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