scalaz-streams의 태스크에서 예외 로깅 및 무시

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