我创建了一个函数,我将输入流作为参数并返回一个由字符串组成的迭代器。我按如下方式完成此操作:
def lineEntry(fileInputStream:InputStream):Iterator[String] = {
Source.fromInputStream(fileInputStream).getLines()
}
我使用的方法如下:
val fStream = getSomeInputStreamFromSource()
lineEntry(fStream).foreach{
processTheLine(_)
}
现在,如果 lineEntry 方法在使用 foreach 遍历输入流时遇到错误字符,很有可能会崩溃。
有哪些方法可以应对这种情况?