等待CombineTest,直到调用#选择器

TL;博士

我需要找到一种安装方法 combineLatest 仅在特定事件之后处理事件的 self.myMethod() 被称为 不使用那种方法订阅 .

描述

我的组件 A 有一个 subscribe() 罗廷 init() ,其中设置了所有接收订阅。

import RxSwift

final class A {

    let bag = DisposeBag()

    init() {
        //...
        subscribe()
    }

    //...

    private func subscribe() {
        // Setup all Rx subscriptions here
    }

还有另外两个依赖项 B 和 C ,每个人都有自己的状态 A. 需要 联合测试 并在组合后生成一些UI事件。

Observable.combineLatest(b.status,
                         c.status)
        .filter { $0.0 == .connecting && $0.1 == .notReachable }
        .map { _ -> Error in
            return AError.noInternet
        }
        .debounce(RxTimeInterval.seconds(5), scheduler: MainScheduler.instance)
        .subscribe(onNext: { [weak self] error in
            self?.didFail(with: error)
        })
        .disposed(by: bag)

A. 它不是一个UI组件,基本上处理业务逻辑,因此它应该等到UI“说”它已经准备好处理业务逻辑。例如,在 myMethod() 被召唤 A. 按用户界面层。

问题

我真的很想 Observable.combineLatest 在里面 订阅 以等待的方式设置 myMethod() 被调用,然后立即从 B 是的 status 和 C 是的 地位 .

目前我是这样做的 A. :

public func myMethod()
    // ... 
    Observable.combineLatest(...
}

,这打破了我正在努力做到的干净准则。