对于一个很常用的两个库， MJRefresh 如何可以像 UIButton 使用方式呢：
btn.rx.tap.subscribe(...)
Rxswift 中的很多类似处理的方式都使用了跟下面极为相似的代码，
进行针对
UIControl的适配时，是通过一个中间层ControlTarget来完成的，为了保持这个ControlTarget实例的存活，使得它不会被自动释放，先用一个集合来包裹住它，并将这个集合设置为目标UIControl的关联对象。此时我们可以将这个中间层ControlTarget看做是这个事件流管道中的一个资源，这个资源的销毁是由目标UIControl来决定的个人写的代码如下：
import UIKit
import MJRefresh
import RxSwift
import RxCocoa class RxTarget: NSObject, Disposable { // RxTarget 是 Rxswift 源码
private var retainSelf: RxTarget?
override init() {
super.init()
self.retainSelf = self
}
func dispose() {
self.retainSelf = nil
}
} final class RefreshTarget<Component:MJRefreshComponent>: RxTarget {
typealias Callback = MJRefreshComponentRefreshingBlock
var callback: Callback?
weak var component:Component? let selector = #selector(RefreshTarget.eventHandler) init(_ component: Component,callback:@escaping Callback) {
self.callback = callback
self.component = component
super.init()
component.setRefreshingTarget(self, refreshingAction: selector)
}
@objc func eventHandler() {
if let callback = self.callback {
callback()
}
}
override func dispose() {
super.dispose()
self.component?.refreshingBlock = nil
self.callback = nil
}
} extension Reactive where Base: MJRefreshComponent {
var event: ControlEvent<Base> {
let source: Observable<Base> = Observable.create { [weak control = self.base] observer in
MainScheduler.ensureExecutingOnScheduler()
guard let control = control else {
observer.on(.completed)
return Disposables.create()
}
let observer = RefreshTarget(control) {
observer.on(.next(control))
}
return observer
}.takeUntil(deallocated)
return ControlEvent(events: source)
}
}
怎么使用呢？
collectionView.mj_header.rx.event
.map { _ in Reactor.Action.refresh }
.bind(to: reactor.action)
.disposed(by: disposeBag) collectionView.mj_footer.rx.event
.map { _ in Reactor.Action.loadMore }
.bind(to: reactor.action)
.disposed(by: disposeBag)
更多内容，请到我的 gitpage