typescript - 如何在不中止序列的情况下仅捕获特定类型的异常

Question

RxJs 似乎没有 catch() 的变体只允许捕获特定类型异常的方法。但是很多时候我发现自己处于需要这样的运算符(operator)的境地。

例如，成像我需要解析日志文件的每一行并打印解析的消息。日志文件的某些行可能已损坏，但我真的不在乎，只想为该行输出“日志消息已损坏”并继续到下一行。

如 catch()确实允许我们指定特定类型的错误来捕获并传递所有其他错误，然后我们可以做一些类似下面的伪代码的事情

readLogs()
.flatMap parseLog
.catchOnly ParseError, () ->
  'Log message corrupted'
.subscribe (logMessage) ->
  console.log logMessage

我想知道考虑到 catach() 的当前限制，RxJs 的正确方法是什么？ .

Answer 1

您需要嵌套 catch为了防止错误终止整个链，您需要分离拆分和解析行的逻辑:

import {of, throwError} from 'rxjs'
import {flatMap, map, catchError} from 'rxjs/operators'



function handleErrors(e) {
    return (e instanceof ParseError) ? 
            of("Log message corrupted") : throwError(e);
}

readLogs().pipe(
  flatMap(splitLines)
  flatMap(line => 
    of(line).pipe(
      map(parseLine), 
      catch(handleErrors)
    )
  )
)
.subscribe(
  parsedLine => console.log(parsedLine),
  e => console.error('Fatal error: ' + e);
);