下面是我的代碼片段。我知道你不應該cachedFlowable這樣阻止，但這只是一個例子。它卡在了線上blockingGet。如果我替換singleOrError為singleElement，代碼仍然會卡住。如果我替換singleOrError為firstElement，代碼將不再卡住。有人可以向我解釋為什么會出現這種情況嗎？ public static void main(String[] args) { final Flowable<Integer> cachedFlowable = Flowable.just(1).cache(); cachedFlowable .doOnNext(i -> { System.out.println("doOnNext " + i); final Integer j = cachedFlowable.singleOrError().blockingGet(); System.out.println("after blockingGet " + j); }) .blockingSubscribe(); }
1 回答
蕭十郎
TA貢獻1815條經驗 獲得超13個贊
它與運算符死鎖的原因singleX是，此類運算符等待可能的第二項發射，但由于您阻止了它們，因此來自主源的任何第二項或完成都無法執行。由于firstX他們只關心第一個項目，因此幾乎立即解鎖，從而允許源完成。
所以是的，您不應該在這樣的流程中使用阻塞方法，而應該使用flatMaporconcatMap執行每個項目的子流程：
var cache = Flowable.just(1).cache();
cache
.doOnNext(i -> System.out.println("doOnNext " + i))
.concatMapSingle(item -> cache.firstOrError())
.doOnNext(j -> System.out.println("after " + j))
.blockingSubscribe();
添加回答
舉報
0/150
提交
取消