假设我有一个应用程序，可以从服务器下载文件并将其上传到另一台服务器。
服务器上不一定存在下载文件。
因此，当文件不存在时，我想跳过它，而不是继续上传它，并确保仅下载/上传现有文件。（即，没有任何一个下载异常会停止所有其他下载和上传过程）
Future应该是成功的，没有结果（单位），或者是失败，并带有失败的路径。
处理这种情况的标准方法是什么？
def downloadFile(path: String): Future[DownloadFile]
def uploadFile(file: DownloadFile): Future[Unit]
Future.sequence(
paths.map { path =>
for {
downloadedFile <- downloadFile(path)
_ <- uploadFile(downloadedFile)
} yield Unit
}
)
考虑
val listOfFutures = List(
Future(1),
Future(throw new RuntimeException("path/foo")),
Future(2),
Future(throw new RuntimeException("path/bar")),
)
Future.traverse(listOfFutures)(_.transform {
case Success(v) => Try(Some(v))
case Failure(e) => Try(None)
}).map(_.flatten) andThen { case v => println(v) }
哪个输出
Success(List(1, 2))
注意Future.sequence是的简单版本Future.traverse。
应用注释，考虑像这样反转拼合
Future.traverse(listOfFutures)(_.transform {
case Success(v) => Try(None)
case Failure(e) => Try(Some(e.getMessage))
}).map { results =>
if (results.flatten.nonEmpty) throw new RuntimeException(s"Bad paths: ${results.flatten.mkString(",")}")
else ()
} andThen { case v => println(v) }
哪个输出
Failure(java.lang.RuntimeException: Bad paths: path/foo,path/bar)
本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
我来说两句