我一直在研究一个搜索 Controller ,当用户在搜索字段中输入时,它使用 RxSwift 更新数据源,就像这里描述的那样:http://www.thedroidsonroids.com/blog/ios/rxswift-examples-3-networking/
那是我的 View 模型:
struct SearchControllerViewModel {
let provider: RxMoyaProvider<ThreadifyEndpoint>
let startsWith: Observable<String>
func startSearching() -> Observable<[SearchedNodeViewModel]> {
return startsWith
.observeOn(MainScheduler.instance)
.flatMapLatest { query -> Observable<[SearchedNodeViewModel]?> in
return self.findNodes(query)
}.replaceNilWith([])
}
internal func findNodes(startsWith: String) -> Observable<[SearchedNodeViewModel]?> {
return self.provider
.request(ThreadifyEndpoint.SearchForNodes(startsWith: startsWith))
.mapArrayOptional(SearchedNodeViewModel.self)
}
}
现在我希望新数据不仅在用户输入时加载,而且在 sh 向下滚动时加载。 我正在考虑使用 combineLatest 来观察 rx_text 和 rx_offset 但由于编译错误我无法将 Observable 传递给 combineLatest。
最佳答案
您看到的编译错误是由于您没有使用实际方法造成的。您打算使用的方法签名是:
public class func combineLatest<O1 : ObservableType, O2 : ObservableType>(source1: O1, _ source2: O2, resultSelector: (O1.E, O2.E) throws -> Element) -> RxSwift.Observable<Element>
请注意,您忘记了第三个参数:resultSelector
。这应该是一个描述您希望如何将最新元素组合成新元素的 block 。
根据您的错误消息,我认为您是这样使用它的:
let combined = Observable.combineLatest(stringObservable, pointObservable)
然而,您应该像这样使用它:
let combined = Observable.combineLatest(stringObservable, pointObservable) { (s, p) in
return "\(s), \(p)" // or construct your new element however you'd like
}
没有 block ,RxSwift 不知道你想如何组合它们。您可能一直认为它只是默认创建一个新的 (String, CGPoint)
元组作为元素,但它没有做出这样的假设并且需要您告诉它。
关于swift - Rx swift : Observe rx_text & rx_offset simultaneously,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/37080718/