स्केलज़-स्ट्रीम में कार्य से अपवाद को लॉगिंग और अनदेखा करना

Question

चलो कुछ स्कालाज़-स्ट्रीम दस्तावेज़ों से एक उदाहरण लें, लेकिन सैद्धांतिक मोड़ के साथ।

import scalaz.stream._ 
import scalaz.concurrent.Task 

val converter: Task[Unit] = 
    io.linesR("testdata/fahrenheit.txt") 
    .filter(s => !s.trim.isEmpty && !s.startsWith("//")) 
    .map(line => fahrenheitToCelsius(line.toDouble).toString) 
    .intersperse("\n") 
    .pipe(text.utf8Encode) 
    .to(io.fileChunkW("testdata/celsius.txt")) 
    .run 

// at the end of the universe... 
val u: Unit = converter.run 

इस मामले में फ़ाइल बहुत अच्छी तरह से कुछ गैर डबल स्ट्रिंग शामिल हो सकता है, और fahrenheitToCelsius कुछ NumberFormatException फेंक देते हैं। आइए मान लें कि इस मामले में हम शायद इस त्रुटि को लॉग करना चाहते हैं और आगे स्ट्रीम प्रोसेसिंग के लिए इसे अनदेखा करना चाहते हैं। ऐसा करने का बेवकूफ तरीका क्या है? मैंने कुछ उदाहरण देखे हैं, लेकिन वे आमतौर पर collectFrom स्ट्रीम करते हैं।

Answer 1

आप scalaz साथ यह कर सकते हैं। \/और अतिरिक्त संसाधन

def fahrenheitToCelsius(line: String): Throwable \/ String = 
    \/.fromTryCatchNonFatal { 
     val fahrenheit = line.toDouble 
     val celsius = fahrenheit // replace with real convert 
     celsius.toString 
    } 

    def collectSome[T]: PartialFunction[Option[T], T] = { 
    case Some(v) => v 
    } 

    def logThrowable[T]: PartialFunction[Throwable \/ T, Option[T]] = { 
    case -\/(err) => 
     err.printStackTrace() 
     None 
    case \/-(v) => Some(v) 
    } 

    val converter: Task[Unit] = 
    io.linesR("testdata/fahrenheit.txt") 
     .filter(s => !s.trim.isEmpty && !s.startsWith("//")) 
     .map(fahrenheitToCelsius) 
     .map(logThrowable) 
     .collect(collectSome) 
     .intersperse("\n") 
     .pipe(text.utf8Encode) 
     .to(io.fileChunkW("testdata/celsius.txt")) 
     .run