如何从可观察的rx中获取最后十个元素？

问题描述

我有一个Observable，它结合了其他三个Observables然后发出一个array。从这个合并的array中，我想获取最后10个对象。但是我想我改用最后十个arrays。首先尝试使用compactMap，但没有成功。它仍然以array

的形式返回

return Observable.combineLatest(breakfast,dessert,cookies) { $0 + $1 + $2 }
    .compactMap { $0 }.takeLast(10)
    .do(onNext: { [weak self] value in
        self?.content.accept(value.compactMap {
            NewRecipesCollectionViewCellviewmodel(recipe: $0)})
        })

解决方法

通过这种方法，您可以一一获取元素：

    let breakfast = Observable.just(["egg","milk"])
    let dessert = Observable.just(["ice cream","chocolate"])
    let cookies = Observable.just(["cookie1","cookie2"])

    Observable.combineLatest(breakfast,dessert,cookies)
        .map { $0 + $1 + $2 }
        .do(onNext: { foods in
            let lastTenFood = foods.suffix(10) // returns the last 10 elements from the array
            for food in lastTenFood {
                print("Food: \(food)")
            }
        })
        .subscribe()
        .disposed(by: disposeBag)