Scalaz akışlarında Görevden günlüğe kaydetme ve görmezden gelme

Question

Bazı scalaz akışlı dokümanlardan bir örnek alalım, ancak teorik bir dönüşle.

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 

Bu durumda dosya çok iyi olmayan bazı çift dize içerebilir ve fahrenheitToCelsius bazı NumberFormatException atar. Bu durumda, belki de bu hatayı günlüğe kaydetmek ve daha fazla akış işlemi için göz ardı etmek istiyoruz. Bunu yapmanın deyimsel yolu nedir? Bazı örnekler gördüm, ancak genellikle collectFrom akışı.

Answer 1

Sen \/ve ek işlem Muhtemelen Scalaz için çok deyimsel

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