Самый идиоматический способ написать try/catch/наконец-то в Scala?

Question

Каков наилучший способ написать следующее в Scala? Это не выглядит совершенно правильно для меня - сначала передняя декларация 2 вал, затем длинная линия создания PrintWriter, затем блок finally. Единственное, что это идиоматическое, является catch блок ...

val outputStream = Try(fs.create(tmpFile)) 
val writer = new PrintWriter(new BufferedWriter(new OutputStreamWriter(outputStream.get))) 

if (outputStream.isFailure) { 
    logger.error(s"Couldn't open file: $tmpFile") 
} 

try { 

    features.foreach { 
    case (sectionName, modelRDD) => 
     writer.append("{" + sectionName + ", " + modelRDD.getNumPartitions + "}") 
    } 

} catch { 
    case e: Exception => 
    logger.error(s"Got exception", e) 
    throw e 

} finally { 
    outputStream.get.close() 
    writer.close() 
} 

Answer 1

Далее мы можем использовать контекст исходного Try выполнить полный операции ввода/вывода:

Во-первых, мы определим функцию, которая инкапсулирует наш процесс:

def safeFilePrint(tf: => OutputStream)(op: PrintWriter => Unit): Try[Unit] = { 
    val os = Try(tf) 
    val write = { 
     val writer = os.map(f => new PrintWriter(f)) 
     val writeOp = writer.map(op) 
     val flushOp = writer.map(_.flush) 
     writeOp.flatMap(_ => flushOp) 
    } 
    val close = os.map(_.close) 
    write.flatMap(_ => close) 
} 

И использование:

val collection = Seq(...) 
val writeResult = safeFilePrint(new FileOutputStream(new File("/tmp/foo.txt"))){w => 
    collection.foreach(elem => w.write(e) 
} 

Обратите внимание, что в отличие от исходного кода мы получаем результат операции записи. Либо writeResult будет Success(()), если все пойдет хорошо или Failure(exception) что-то пошло не так. Исходя из этого наше приложение может дополнительно решить, что делать.

Можно задаться вопросом: «Где finally?» В Java finally используется для обеспечения выполнения некоторого кода (обычно управления ресурсами) даже в том случае, если исключение, созданное в области try, приведет к следующему пути обработки исключений.

В Scala, используя конструкции типа Try, Either или наш собственный ADT, мы поднимаем обработку ошибок на уровень приложения. finally становится ненужным, так как наша программа может справиться с отказом как просто другое действительное состояние программы.

Answer 2

Наконец-то этот код был прочитан после прочтения ответа @ maasg, в котором подчеркивается монадический поток и более «симметричный». Он выглядит намного лучше, чем код в OP!

def safePrintToStream(gen: => OutputStream)(op: PrintWriter => Unit): Try[Unit] = { 
    val os = Try(gen) 
    val writer = os.map(stream => new PrintWriter(stream)) 
    val write = writer.map(op(_)) 
    val flush = writer.map(_.flush) 
    val close = os.map(_.close) 
    write.flatMap(_ => flush).flatMap(_ => close) 
}