我正在使用RxJava将应用程序重构为响应式范例。我正在逐步进行，所以我需要使用toBlocking()在某些情况下，暂时为了尊重接口(interface)。使用时如何处理错误toBlocking()？之前，我有这样的事情:publicListgetEmployees(){try{returnrepository.getEmployees();}catch(Exceptione){thrownewMyCustomException();}}现在，存储库有一个react接口(interface)(返回Observable>)，所以我这样做:publicListgetEmployees()

我目前在Android上使用RxJava和Kotlin，但我有一个问题，如果不使用toBlocking()就无法解决。我在员工服务中有一个返回Observable的方法>:funall():Observable>这一切都很好，因为只要员工发生变化，这个Observable就会发出新的员工列表。但我想从员工那里生成一个PDF文件，显然不需要在每次员工变动时都运行。另外，我想从我的PDF生成器方法返回一个Completable对象。我想在我的PDF中添加一个标题，然后遍历员工并计算每个员工的工资，这也返回一个Observable，这就是我现在使用toBlocking的地方。我目前的做法是: