RxSwift。 CombineLatest。并非所有可观测量都被发射出去

问题描述 投票:2回答:1

Observable.combineLatest(...){...}包含几个可观察对象,但是没有发出一些这些可观察对象。

只有在发出此方法中的所有可观察对象时,combineLatest才会发出。

如何跳过不发出的observable并发出combineLatest?

let tap = firstButton.rx.tap.asObservable().map{ (_) -> Observable<Item> ...}

let textfieldObservable = viewTextField.rx.text.orEmpty.asObservable()

submitButton.rx.tap.withLatestFrom(Observable.combineLatest(textfieldObservable, tap ... )).flatMapLatest({
...
// this method will not be executed without tap on firstButton before tapping on submitButton

}
)
ios swift rx-swift rx-cocoa
1个回答
16
投票

combineLatest使用一个闭包,它结合了可观察量的参数。所以它有意义等待它所结合的所有可观察对象在它调用它的闭包之前提供一个值。

但是如果你能找到提供给combineLatest的每个可观察量的sain默认值,你可以使用startWith(_:)强制它们具有初始值。

这是使用nilitemtext的空字符串的代码

let tapObservable: Observable<Item> = // ...
let textField: Observable<String> = // ...

let combined = Observable.combineLatest(
  tapObservable.map { /* map everything to optional */ Optional.some($0) }.startWith(nil), 
  textField.startWith("")
) { item, text in
  // combine item and text
}

submitButton.rx.tap.withLatestFrom(combined)
© www.soinside.com 2019 - 2024. All rights reserved.