RxSwift过滤器变量数组

Question

您好我正在尝试了解RxSwift库以编写更好的功能代码.

目前我陷入了一个非常基本的问题.可以说我得到了这种类型的变量Variable<[CiteModel?]>:

var allCites: Variable<[CiteModel?]> = Variable([])
var shownCites: Variable<[CiteModel?]> = Variable([])

现在我想过滤allCites包含特定文本的数组中的所有引用并将它们添加到shownCites.

这是我试过,但它并没有编译,因为在我的过滤器块$0是[CiteModel?] 不是 CiteModel?我所期望的那样.你能解释一下我做错了什么吗？

private func filterCitesByQuery(query: String) {
    self.shownCites = self.allCites.asObservable().filter {
        $0?.cite.containsString(query)
    }
}

执行上述代码时出错:

Cannot assign value of type 'Observable<[CiteModel?]>' (aka 'Observable<Array<Optional<CiteModel>>>') to type 'Variable<[CiteModel?]>' (aka 'Variable<Array<Optional<CiteModel>>>')

Answer 1

map对序列的每个值执行操作.当应用于mapa时Observable<T>,map将T作为参数接收到其块.

在的情况下Variable<[CiteModel?]>,Observable是序列因此T == [CiteModel?].

因为我们真的想要过滤一个数组[CiteModel?],你可以改变filterCitesByQueryto 的定义

private func filterCitesByQuery(query: String) {
    // bag probably needs to be reset here
    allCites.asObservable()
        .map { // map: apply a transformation to $0
        // The desired transformation of $0 is to remove cite that do not contain query 
        $0.filter { $0.cite.containsString(query) }
    }
    .bindTo(shownCites)
    .addDisposableTo(bag)
}

但是这个片段仍然是次优的,因为它需要订阅allCites,我们并不真的想要观察它的变化.

一个更好的实施将是

var allCites: Variable<[CiteModel?]> = Variable([])
var searchQuery: Variable<String> = Variable("")
var shownCites: Observable<[CiteModel?]> = Observable .combineLatest(allCites.asObservable(), searchQuery.asObservable()) {
    allCites, query in
    return allCites.map { cites in cites.filter { $0.cite.containsString(query) } }
}

private func filterCitesByQuery(query: String) {
    searchQuery.value = query
}

这里发生了什么 ？

combineLatest采用的最后2个已知值allCites和searchQuery.当其中任何一个发生更改时,都会执行该块.我们现在可以订阅shownCites并在每次源可观察的更改时获得更新的值.