如何在RxJava2中正确发布资源？
我正在使用Selenium和ChromeDriver用Java语言编写一个刮板，我想把它包装成可观察的(为了更容易的异步)。这是从我的解析器类返回Observable的代码：
return Observable.interval(5000, 5000, TimeUnit.MILLISECONDS)
.doOnSubscribe(ignored -> initialize())
.doOnNext(ignored -> refreshPage())
.map(ignored -> getHtml())
.map(this::parse)
.flatMap(Observable::fromIterable)
.doFinally(() -> finish())
.share();因此，在这里，initialize()基本上创建了Selenium WebDriver的配置实例，refreshPage()重新加载页面并等待它加载，getHtml()就是driver.getPageSource()，finish()就是driver.quit()，而driver是Selenium WebDriver的一个实例。我遇到的问题是，我订阅了这个可观察对象，然后又将其处理掉。我从refreshPage()得到一个异常，说我在driver.quit()之后调用了driver上的一个方法(或者在上面的代码中，这意味着refreshPage()是在finish()之后调用的)。
我应该如何创建/修改我的源观察值，以便在处置时正确释放我的资源？(我希望finish()总是在可观察链中的其他所有操作完成后调用)。
更新:我的finish()函数是：
public void finish() {
driver.quit();
}回答 1
Stack Overflow用户
发布于 2018-09-23 10:36:50
doFinally所做的正如您所怀疑的。它在以下情况下执行关联的Action：
onError，onComplete，or- 关联的下游取消/处置流
但是，我怀疑可能发生的情况是，您可能在finish()的主体中调用driver.quit()，而不是在它返回的Action中调用。假设在refreshPage()中使用了driver，这个错误是有意义的，因为实际调用doFinally()本身(而不是它返回的Action )是为了构建流行为，而refreshPage()是流中最早使用driver的点。
如果你的代码看起来像这样：
private Action finish() {
driver.quit();
return () -> {
...
};
}...then将对quit()的调用移到Action的主体中，如下所示：
private Action finish() {
return () -> {
driver.quit();
};
}如果我的假设是错误的，你能用finish()的代码更新这个问题吗？我很想看看那里发生了什么。
https://stackoverflow.com/questions/52460460
复制相似问题