RxSwift с использованием сбора данных

Question

Это мой первый раз, когда я использую rxSwift

Я пытался использовать rxswift для наблюдения за сбором данных и обновления представления, но я делаю что-то не так

Я сделалтаймер для добавления элемента в сбор данных, который по умолчанию начинается с 1 элемента, но представление коллекции не обновляется.

import Foundation
import UIKit
import MaterialComponents
import RxSwift
import RxCocoa

class MainFeedViewController : BaseViewController
{
    var loveData: [FeedDataModel] = []
    var collectionData : Observable<[FeedDataModel]>? = nil

    var collectionView : UICollectionView? = nil
    var cellId = "FeedCollectionViewCell"

    let disposeBag = DisposeBag()

    override func viewDidLoad() {
        super.viewDidLoad()

        loadDummyData()

        initCollectionView()

        self.view.addConstraint(NSLayoutConstraint(item: self.view, attribute: .height, relatedBy: .equal, toItem: collectionView, attribute: .height, multiplier: 1, constant: 0))
        self.view.addConstraint(NSLayoutConstraint(item: self.view, attribute: .width, relatedBy: .equal, toItem: collectionView, attribute: .width, multiplier: 1, constant: 0))

    }

    private func initCollectionView()
    {
        collectionView = UICollectionView(frame: CGRect.zero, collectionViewLayout: UICollectionViewFlowLayout.init())
        collectionView!.register(UINib(nibName: cellId, bundle: nil), forCellWithReuseIdentifier: cellId)
        collectionView!.delegate = self
    //collectionView!.dataSource = self
        collectionView!.backgroundColor = UIColor.groupTableViewBackground
        collectionView?.translatesAutoresizingMaskIntoConstraints = false

        collectionData!.bind(to: collectionView!.rx.items(cellIdentifier: cellId))
        {
            _, data, cell in
            let a = cell as! FeedCollectionViewCell
            a.imgMAIN.downloaded(link: (data.image?.absoluteString)! )
            a.lblTitle.text = data.title

        }.disposed(by: disposeBag)

        collectionView?.rx.modelSelected(FeedDataModel.self).subscribe {
            next in
            }.disposed(by: disposeBag)

        self.view.addSubview(collectionView!)
    }

    override func viewDidAppear(_ animated: Bool)
    {
//        DispatchQueue.main.async {
//            self.collectionView?.reloadData()
//        }

        Timer.scheduledTimer(timeInterval: 5, target: self, selector: #selector(addObj), userInfo: nil, repeats: true)
    }

    private func loadDummyData()
    {
        addObj()
        collectionData = Observable.just(loveData)
    }

    @objc func addObj()
    {
        let obj1 = FeedDataModel.init(image: "https://via.placeholder.com/150",title: "Placeholder")

        print("adding object")
        loveData.append(obj1)
    }

}

Можете ли вы указать мне правильное направление?

спасибо

Answer 1

Хорошо ...

Конструктор Observable.just(loveData) создаст Observable, который генерирует массив один раз и затем завершается.В конечном итоге вам нужно будет перечислить все входные данные, которые могут привести к изменению представления сбора, и использовать их в качестве входных данных в collectionData Observable.

Но сейчас, чтобы ваши ноги промокли, выможно просто использовать тему:

class MainFeedViewController : BaseViewController
{
    var loveData: [FeedDataModel] = []
    let collectionData = PublishSubject<[FeedDataModel]>()

// ...

collectionData.asObservable().bind(to: collectionView!.rx.items(cellIdentifier: cellId))

// ...

private func loadDummyData()
{
    addObj()
    collectionData.onNext(loveData)
}

@objc func addObj()
{
    let obj1 = FeedDataModel.init(image: "https://via.placeholder.com/150",title: "Placeholder")

    print("adding object")
    loveData.append(obj1)
    collectionData.onNext(loveData)
}

Класс PublishSubject является самым основным типом субъекта.Он действует как Наблюдаемый и Наблюдатель.Таким образом, вы можете вставить значения в него с помощью onNext(), и когда вы это сделаете, он отправит эти значения любому наблюдателю, который подписывается или привязывается к нему.Поскольку представление вашей коллекции связано с ним, это означает, что представление коллекции будет получать события по мере их отправки.

Но это только начало!Использование подобного предмета - это всего лишь способ преобразовать императивный код в декларативный стиль, к которому вас подталкивает Rx.

Чтобы воспользоваться всеми преимуществами системы, вам придется думать немного по-другому.Вместо того, чтобы думать: «Когда пользователь делает X, приложение должно делать Y».вам придется систематизировать свои мысли в духе: «Этот вывод изменяется всякий раз, когда происходят такие вещи».

Возможно, это так же просто, как: «Представление коллекции должно обновляться из сетевого запроса всякий раз, когда пользователь нажимает накнопка обновления. Если запрос не удался, не обновляйте список. "Что бы выглядело примерно так:

refreshButton.rx.tap
    .flatMap {
        getRequestResponse()
            .catchError { _ in Observable.empty() }
    }
    .bind(to: collectionView!.rx.items(cellIdentifier: cellId, cellType: FeedCollectionViewCell.self))  { _, data, cell in
        cell.imgMAIN.downloaded(link: (data.image?.absoluteString)! )
        cell.lblTitle.text = data.title
    }
    .disposed(by: disposeBag)

Или то, что, по-видимому, хотел видеть ваш код: «Сборное представление должно начинаться с одной записи и получать дополнительную запись каждые 5 секунд».Который будет выглядеть примерно так:

Observable<Int>.interval(5, scheduler: MainScheduler.instance)
    .scan(into: [FeedDataModel.init(image: "https://via.placeholder.com/150",title: "Placeholder")]) { current, _ in
        current.append(FeedDataModel.init(image: "https://via.placeholder.com/150",title: "Placeholder"))
    }
    .bind(to: collectionView!.rx.items(cellIdentifier: cellId, cellType: FeedCollectionViewCell.self))  { _, data, cell in
        cell.imgMAIN.downloaded(link: (data.image?.absoluteString)! )
        cell.lblTitle.text = data.title
    }
    .disposed(by: disposeBag)