java - RxJava- CombineLatest 但仅针对一个 Observable 的发射触发？

Question

假设我有两个可以随时发出值的无限 Observable。他们结合创造了一个 Observable<ProcessFileEvent> .

Observable<Integer>  selectedFileId= ...
Observable<MouseClick> buttonClick = ...

Observable<ProcessFileEvent> `processFileEvent` = Observable.combineLatest(selectedFileId, buttonClick, (s,b) -> {
    //create ProcessFileEvent here
});

问题是我只希望 processFileEvent 在 buttonClick 时发出发出一些东西，而不是 selectedFileId .当输入文件 ID 并启动 ProcessFileEvent 时，这绝对不是用户期望的行为。 .如何组合但仅在 buttonClick 时发出发射？

Answer 1

使用withLatestFrom :

Observable<Integer>  selectedFileId= ...
Observable<MouseClick> buttonClick = ...

Observable<ProcessFileEvent> processFileEvent = buttonClick.withLatestFrom(selectedFieldId, (b,s) -> {
    //create ProcessFileEvent here
});

它仅在第一个 Observable buttonClick 发出时发出。