经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置：技术经验 » 移动开发 » Swift » 查看文章
RxSwift实现替换delegate的方法示例
来源：jb51　　时间：2019/9/12 11:42:07　　对本文有异议

目标

最近写项目 ，写到需要为自己写的一个控件添加rx订阅方式的案例。

目前有一个代理：

  1. // 代理方式获取结果
  2. @objc public protocol ZZPhotoPickerControllerDelegate : NSObjectProtocol {
  3.  @objc optional func photoPickerController(_ photoPickerController: ZZPhotoPickerController, didSelect assets: [Any])
  4. }

需要写一个能够实现下边这种方式的扩展

  1. photoPickerController.rx.assetsSelected.subscribe(onNext: { assets in
  2.  // do something
  3. }

思路

刚开始完全摸不着头脑。后来想到Rx写了对UICollectionViewDelegate的扩展：

  1. collectionView.rx.itemSelected.subscribe(onNext: { indexPath in
  2.  // do something
  3. }

跟我的需求是一样的。

于是就去看itemSelected的源代码：

  1. /// Reactive wrapper for `delegate` message `collectionView(_:didSelectItemAtIndexPath:)`.
  2.  public var itemSelected: ControlEvent<IndexPath> {
  3.   let source = delegate.methodInvoked(#selector(UICollectionViewDelegate.collectionView(_:didSelectItemAt:)))
  4.    .map { a in
  5.     return try castOrThrow(IndexPath.self, a[1])
  6.    }
  7.   
  8.   return ControlEvent(events: source)
  9.  }

souce是一个Observable，由delegate.methodInvoked产生。delegate是什么delegate？为什么会有methodInvoked方法？于是继续点进去。

  1. extension Reactive where Base: UIScrollView {
  2.    /// ...这部分代码省略不用看
  3.  
  4.   /// Reactive wrapper for `delegate`.
  5.   ///
  6.   /// For more information take a look at `DelegateProxyType` protocol documentation.
  7.   public var delegate: DelegateProxy<UIScrollView, UIScrollViewDelegate> {
  8.    return RxScrollViewDelegateProxy.proxy(for: base)
  9.   }
  10.   
  11.   /// ...后面的代码暂时也不用看
  12. }

可以看到delegate是一个DelegateProxy<UIScrollView, UIScrollViewDelegate>类型，根据字面是理解就是代理的代理。然后还看到这里的rx是扩展自UIScrollView的，UICollectionView是继承自UIScrollView，可以知道这里的delegate也是继承过来的使用的。还可以看到RxScrollViewDelegateProxy这个东西，可以想到如果我们要仿写的话，自己也应该写这样一个代理的代理类。先点进去看看：

  1. open class RxScrollViewDelegateProxy
  2.  : DelegateProxy<UIScrollView, UIScrollViewDelegate>
  3.  , DelegateProxyType 
  4.  , UIScrollViewDelegate {
  5.  
  6.  /// Typed parent object.
  7.  public weak private(set) var scrollView: UIScrollView?
  8.  
  9.  /// - parameter scrollView: Parent object for delegate proxy.
  10.  public init(scrollView: ParentObject) {
  11.   self.scrollView = scrollView
  12.   super.init(parentObject: scrollView, delegateProxy: RxScrollViewDelegateProxy.self)
  13.  }
  14.  
  15.  // Register known implementations
  16.  public static func registerKnownImplementations() {
  17.   self.register { RxScrollViewDelegateProxy(scrollView: $0) }
  18.   self.register { RxTableViewDelegateProxy(tableView: $0) }
  19.   self.register { RxCollectionViewDelegateProxy(collectionView: $0) }
  20.   self.register { RxTextViewDelegateProxy(textView: $0) }
  21.  }
  22.  
  23.  /// ...后面的感觉没什么关系，先不看
  24. }

可以看到它其实是一个DelegateProxy<UIScrollView, UIScrollViewDelegate>，并且遵守了DelegateProxyType和UIScrollViewDelegate协议，可以感觉出它是一个链接rx和delegate的纽带。有一个实例变量scrollView，有一个init方法，有一个registerKnownImplementations静态方法。

现在脑海中大概有一个模糊的思路：我们要先创建一个纽带delegateProxy对象，然后在目标类的rx扩展中创建一个delegateProxy实例，最后在我们的assetsSelected事件流中用这个delegateProxy的methodInvoked截获delegate中的目标方法，并生成可订阅的Observable返回给controlEvent，这样链接打通。

开动

首先创建一个RxPhotoPickerControllerDelegateProxy

  1. class RxPhotoPickerControllerDelegateProxy: DelegateProxy<ZZPhotoPickerController, ZZPhotoPickerControllerDelegate>, DelegateProxyType, ZZPhotoPickerControllerDelegate {
  2.  
  3.  /// Typed parent object.
  4.  public weak private(set) var photoPickerController: ZZPhotoPickerController?
  5.  
  6.  /// - parameter scrollView: Parent object for delegate proxy.
  7.  public init(photoPickerController: ParentObject) {
  8.   self.photoPickerController = photoPickerController
  9.   super.init(parentObject: photoPickerController, delegateProxy: RxPhotoPickerControllerDelegateProxy.self)
  10.  }
  11.  
  12.  static func registerKnownImplementations() {
  13.   self.register { RxPhotoPickerControllerDelegateProxy(photoPickerController: $0) }
  14.  }
  15.  
  16.  // 把上面的写好后，编辑器会提示你需要实现一下两个方法，一个是获取，一个是设置，所以很好理解该在方法里实现什么。
  17.  static func currentDelegate(for object: ZZPhotoPickerController) -> ZZPhotoPickerControllerDelegate? {
  18.   return object.zzDelegate
  19.  }
  20.  
  21.  static func setCurrentDelegate(_ delegate: ZZPhotoPickerControllerDelegate?, to object: ZZPhotoPickerController) {
  22.   object.zzDelegate = delegate
  23.  }
  24.  
  25. }

然后给目标的rx扩展写一个delegateProxy实例：

  1. extension Reactive where Base: ZZPhotoPickerController {
  2.  
  3.  public var zzDelegate: DelegateProxy<ZZPhotoPickerController, ZZPhotoPickerControllerDelegate> {
  4.   return RxPhotoPickerControllerDelegateProxy.proxy(for: base)
  5.  }
  6.  
  7. }

最后写我们的assetsSelected：

  1. extension Reactive where Base: ZZPhotoPickerController {
  2.  
  3.  var assetsSelected: ControlEvent<[Any]> {
  4.   let source: Observable<[Any]> = self.zzDelegate.methodInvoked(#selector(ZZPhotoPickerControllerDelegate.photoPickerController(_:didSelect:))).map { a in
  5.    return a[1] as! [Any]
  6.   }
  7.   return ControlEvent.init(events: source)
  8.  }
  9.  
  10. }

要注意里面有个方法castOrThrow，这个方法rx并没有开放出来，是个内部方法，如果照着写报错。可以研究出该方法只是一个类型推断而已，所以可以简单写。

完成

然后就可以愉快的去对assetsSelected进行订阅了。

  1. vc.rx.assetsSelected.subscribe(onNext: { (assets) in
  2.     // do something
  3.    }).disposed(by: self.disposeBag)

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，谢谢大家对w3xue的支持。

 友情链接：直通硅谷 　点职佳 　北美留学生论坛

Swift热门文章

  • Swift使用AlamoFire超时设置和事件处理
  • Swift 在UIWindow 上添加并移除 view
  • SwiftUI学习之state和Binding的区别浅析
  • iOS Swift 二维码扫码，自定义全屏拍照，系统相册图片编辑多选，系统相册图片浏览， 就用WisdomScanKit SDK
  • 【Swift】GRDB数据库本地存储聊天记录
  • 【Swift 4.0】扩展 WCDB 支持 SQL 语句
  • CEPH Object Gateway
  • Swift函数调用方式浅析
  • ubuntu 下 go 语言调试器 dlv 的安装
  • iOS基础UI控件介绍-Swift版

    • Swift推荐文章

  • 万字长文详解如何使用Swift提高代码质量
  • Swift中的高阶函数功能作用示例详解
  • Swift中的HTTP请求体Request&nbsp;Bodies使用示例详解
  • 【Swift】GRDB数据库本地存储聊天记录
  • 【Swift】拆分小说阅读器功能，分享内部实现
  • Swift 面试题 - 雄霸天下-无人能挡
  • Swift--面试题及答案 - 雄霸天下-无人能挡
  • OC方法交换swizzle详细介绍——不再有盲点
  • 【Swift】WKWebView与JS的交互使用
  • CEPH Object Gateway

    • 本站QQ群：前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

    W3xue 的所有内容仅供测试，对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
    关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接（目前9元/月）请联系QQ：27243702 沸活量
    皖ICP备17017327号-2　皖公网安备34020702000426号