3

我编写了如下的小演示代码。我制作了两个不同类型的 PublishSubject。当我更改任何页面触发器时，我只需要在一个更改时获取页面触发器，哪个observable_page。

class ViewController: UIViewController {

    func loadData(page: Int, keyword: String) -> Observable<[Int]> {
        let _result = Observable.of([1,2,3,4])
        return _result
    }

    override func viewDidLoad() {
        super.viewDidLoad()
        // Do any additional setup after loading the view, typically from a nib.

        let observable_keyword = PublishSubject<String>()
        let observable_page = PublishSubject<Int>()
        let trigger_tap = PublishSubject<Void>()

        let tapObservable = trigger_tap.debug("trigger_tap", trimOutput: true)
        let stringObservable = observable_keyword.debug("stringObservable", trimOutput: true)
        let pageObservable = observable_page.debug("pageObservable", trimOutput: true)

        let request_call_trigger = Observable.combineLatest(tapObservable, pageObservable)
            .debug("request_call_trigger", trimOutput: true)

        let page = request_call_trigger
            .withLatestFrom(stringObservable) { ($0, $1) }
            .flatMap { ((_, _, page), keyword) in
                Observable.combineLatest(Observable.just(page), self.loadData(page: page, keyword: keyword)) { (pageNumber: $0, movies: $1) }
                    .materialize()
                    .filter { $0.isCompleted == false }
            }
            .share()

        observable_keyword.onNext("breaking bad")
        observable_page.onNext(1)

        trigger_tap.onNext(())

        observable_keyword.onNext("orange is new black")
        observable_keyword.onNext("orange")

    }

    let bag = DisposeBag()
}

我读了一些选项，觉得过滤器或忽略可能在这里有用，但是因为我需要它们的价值，所以很困惑，如何正确应用它。

4

2 回答 2

5

如果您正在寻找单个触发器，我认为您寻找的运算符是withLatestFrom：

observable2
  .withLatestFrom(observable1)

意思是：仅当observable2发生变化时 - 获取其最新发出的值以及 observable1 的最新发出的值。

编辑：如果您想要两个值，您可能需要提供resultsSelector：

observable2
  .withLatestFrom(observable1) { ($0, $1) }
于 2018-10-28T20:26:24.830 回答
0

您可以使用withLatestFrom根据文档

通过将 self 中的每个元素与第二个源中的最新元素（如果有）组合，将两个可观察序列合并为一个可观察序列

在您的代码中 request_call_trigger 是Observable<(Void, Int>)您结合使用的最新值的stringObservable类型withLatestFrom。这产生了另一个类型的元组Observable<(((Void, Int), String)>

您可以flatMap在使用创建的元组上，withLatestFrom并将页面和关键字值传递给loadData方法，方法是使用页面的元组值为 $0.1，因此无需在 flatMap 中使用 combineLatest。

        let tapObservable = trigger_tap.debug("trigger_tap", trimOutput: true)
        let stringObservable = observable_keyword.debug("stringObservable", trimOutput: true)
        let pageObservable = observable_page.debug("pageObservable", trimOutput: true)

        let request_call_trigger: Observable<(Void, Int)> = Observable.combineLatest(tapObservable, pageObservable)
            .debug("request_call_trigger", trimOutput: true)

        _ = request_call_trigger
            .withLatestFrom(stringObservable) { ($0, $1) }
            .flatMap { [weak self] (request_page_tuple: (Void, Int), keyword: String) -> Observable<Event<[Int]>> in
                guard let strongSelf = self else {
                    return Observable.empty()
                }
                return strongSelf
                    .loadData(page: request_page_tuple.1, keyword: keyword)
                    .materialize()
                    .filter { !$0.isCompleted }
            }
            .share()
于 2018-10-29T12:09:51.587 回答