scala - 将订阅 onError Scala.RX 放入 Observable 是否有害?
问题描述
我正在使用一个rx.lang.scala
用于理解的,我想快速失败。parameters
如果发生异常,我还希望关闭资源。如果您抛出 Exception / Throwable,doOnTerminate 是否会正确执行,如下面提供的示例所示?
private def createAgreement(parameters: Params, output: ByteArrayOutputStream): Try[Unit] = Try {
output
.usedIn(AgreementCreator(parameters).createAgreement) //Observable.using(resource)(observableFactory, t => { dispose(t); IOUtils.closeQuietly(t) }, disposeEagerly)
.doOnTerminate(parameters.close()) //close resource
.toBlocking
.subscribe(_ => {},
e => throw e,
() => debug("completed"))
}
解决方案
推荐阅读
- node.js - 无法使用 systemd 运行节点应用程序
- android - Kotlin RecycleView 无法正常工作
- python - 如何在python中对具有浮点值的列表进行排序?
- python - 模拟用户对 Python 脚本运行的子进程的输入
- android - RecyclerView 不显示任何数据
- javascript - 使用 href="#About us" 在一个站点上导航不适用于较小的设备
- hadoop - 监控和检查YARN的状态
- django - 分发“干净”的 Django 项目源代码
- azure-sql-database - 无法使用 sqlpackage.exe 将 DACPAC 发布到 Azure SQL 数据库
- visual-studio - 有没有办法在 Atmel Studio 的内存窗口中标记行