在 UICollectionViewCell 中为 UIButton 设置 rx.tap 的问题 - RxSwift 3

Question

我为 1 个 UIButton 订阅了 2 次：

1. 首次订阅，每次点击都会更新 UI
2. 二次订阅，累计点击后每1秒更新一次Web Service上的值。

代码：

class ProductionSize {
    var id : Int?
    var size: Int = 0
    var name: String = ""
}

class ProductionCell: UICollectionViewCell {
    var rxBag = DisposeBag()


    // this will be set in the (cellForItemAt indexPath: IndexPath) of collection view
    var productionSize: ProductionSize? {
        didSet {
            showProductionSize()
            prepareButton()
        }
    }

    func showProductionSize() {
        // ... code for showing ProductionSize in labels
    }

    func prepareButton() {
        // This for subscribing for every click for displaying purpose

        btn_increase.rx.tap
            .subscribe(){event in 
                self.increaseClicked() 
            }
            .addDisposableTo(rxBag)

        // this for subscribing for sending webservice request after 1 second of clicking the button (so that if user click it quickly i send only last request)

        btn_increase.rx.tap
            .debounce(1.0, scheduler: MainScheduler.instance)
            .subscribe(){ event in self.updateOnWS() }
            .addDisposableTo(rxBag)
    }

    func increaseClicked() {
        productionSize.size = productionSize.size + 1
        showProductionSize()
    }

    func updateOnWS() {
        // code for updating on webservice with Moya, RxSwift and Alamofire§
    }


    // when scrolling it gets called to dispose subscribtions
    override func prepareForReuse() {
        rxBag = DisposeBag()
    }

}

问题：

由于处理发生在prepareForReuse()，如果我多次单击按钮并立即滚动，webservice 调用将被处理而不更新。

我尝试过的：

1. 在父 ViewController DisposableBag 中添加了addDisposableTo(vc?.rx_disposableBag)。

   问题，订阅累积，每次点击updateWS()都会被调用很多次，每次滚动都订阅了，从未被释放。

2. 我已尝试从prepareForReuse() 中删除disposableBag 重新初始化。

   问题，再次重复和累积按钮的订阅，并且每次点击都会调用许多 Web 服务调用。

问题： 我怎样才能让debounce 订阅被调用到最后并且从不重复多个订阅（如果是addDisposableTo viewController Bag）？

Answer 1

由于prepareButton() 总是在集合视图的 (cellForItemAt indexPath: IndexPath) 中被调用，你可以试试这个：

func prepareButton() {

    self.rxBag = nil 
    let rxBag = DisposeBag()

    // This for subscribing for every click for displaying purpose

    btn_increase.rx.tap
        .subscribe(onNext: { [weak self] _ in 
            self?.increaseClicked()
        })
        .addDisposableTo(rxBag)

    // this for subscribing for sending webservice request after 1 second of clicking the button (so that if user click it quickly i send only last request)

    btn_increase.rx.tap
        .debounce(1.0, scheduler: MainScheduler.instance)
        .subscribe(onNext: { [weak self] _ in 
            self?.updateOnWS()
        })
        .addDisposableTo(rxBag)

    self.rxBag = rxBag
}

删除prepareForReuse() 实现。

Answer 2

在父 ViewController DisposableBag 中添加了addDisposableTo(vc?.rx_disposableBag)。

问题是，订阅的累积和每次点击都会调用 updateWS() 多次，每次滚动都会订阅并且从未处理过。

由于您订阅按钮的点击方式，您的self.updateOnWS() 可能会被多次调用。

    btn_increase.rx.tap
        .debounce(1.0, scheduler: MainScheduler.instance)
        .subscribe(){ event in self.updateOnWS() }
        .addDisposableTo(rxBag)

如您所见，您使用subscribe() 方法订阅所有事件。这意味着所有 Rx 事件（onNext、onError、onCompleted、onSubscribed 和 onDisposed）都会触发 self.updateOnWS()。您可以通过打印出event 对象来检查是否是这种情况，以查看触发了什么事件。

仅订阅onNext

一个可能的解决方法是只订阅onNext 操作。

    btn_increase.rx.tap
        .debounce(1.0, scheduler: MainScheduler.instance)
        .subscribe(onNext: { [weak self] (_ : Void) in
               self?.updateOnWS() 
        })
        .addDisposableTo(vc?.rxdisposableBag)

通过使用视图控制器的DisposeBag，即使单元格被释放（向下滚动时），您也可以确保操作仍然继续。但是，如果您需要在处置单元格时处置订阅，请使用单元格的DisposeBag，而不是视图控制器。

旁注 - 内存泄漏

注意self 的引用被指定为弱引用，这样可以防止发生内存泄漏。通过将其指定为弱，它将为您提供对 self 的引用，该引用是可选的。

如果不这样做，您为 onNext 块创建的闭包将保留对 self 的强引用，即您的 UICollectionViewCell，而后者又拥有我们正在讨论的闭包。

这最终会导致内存不足崩溃。请参阅我在您的问题的 cmets 上发布的参考资料，了解更多关于错误引用 self 导致的内存泄漏的信息。