RxSwift-拓展RxCocoa

泊学看来的,记录一下,忘了回来翻一下,理论不好记,让代码说明一切

扩展CoreLocation

实话说,搞清楚RxCocoa处理UIKit delegate的机制略显复杂。简单来说,就是它设置了一个delegate proxy,这个proxy可以替我们从原生delegate获取数据,然后变成Observables供我们使用。而我们要做的,就是自己为CLLocationManager定义一个这样的proxy,然后注册到RxCocoa就行了。这个过程要比理解这个机制的细节,简单多了。大体上说,分成三步。

首先,在Extensions group中,添加一个CLLocationManager+Rx.swift文件,这也是符合RxCocoa命名约定的做法;

其次,我们要告诉RxCocoa,CLLocationManager是一个有delegate的类型,这是让它遵从HasDelegate实现的。HasDelegate是RxCocoa定义的一个protocol,它有两个约束,一个是Delegate,表示原生delegate的类型,这里,当然就是CLLocationManagerDelegate:

extension CLLocationManager: HasDelegate {
    public typealias Delegate = CLLocationManagerDelegate
}

另一个是delegate对象,我们稍后再说。

第三,我们就要实现CLLocationManagerDelegate的proxy了。先来看它的声明:

class CLLocationManagerDelegateProxy:
    DelegateProxyType,
    CLLocationManagerDelegate,
    DelegateProxy<CLLocationManager, CLLocationManagerDelegate>

这里:

DelegateProxyType是RxCocoa定义的protocol,它约束了RxCocoa中,delegate proxy的接口;
而DelegateProxy<CLLocationManager, CLLocationManagerDelegate>可以理解为是遵从DelegateProxyType的一份标准实现,这份实现需要两个泛型参数,分别是类型自身和与这个类型搭配工作的原生Delegate类型;
最后,作为CLLocationManager的delegate proxy,我们当然得让它也遵从CLLocationManagerDelegate;
理解了这个声明之后,实现它就容易多了,首先是它的属性和init方法,无非就是创建一个CLLocationManager对象,并传递我们期望的CLLocationManager的delegate proxy类型:

class CLLocationManagerDelegateProxy:
    DelegateProxyType,
    CLLocationManagerDelegate,
    DelegateProxy<CLLocationManager, CLLocationManagerDelegate>, {
    weak private(set) var locationManager: CLLocationManager?

    init(locationManager: ParentObject) {
        self.locationManager = locationManager
        super.init(parentObject: locationManager,
            delegateProxy: CLLocationManagerDelegateProxy.self)
    }
}

完成后,唯一需要我们实现的一个DelegateProxyType方法是registerKnownImplementations。它用于向RxCocoa注册我们自定义的DelegateProxyType:

static func registerKnownImplementations() {
    self.register {
        CLLocationManagerDelegateProxy(locationManager: $0)
    }
}

至此,RxCocoa中的delegate proxy机制理论上就有能力可以转发CLLocationManagerDelegate的方法了。但我们还没法使用它,而这就是我们接下来要完成的部分。

最后,给CLLocationManager对象添加rx扩展。这里,我们稍微多做一点功课,先来了解下rx这个“名字空间”是怎么来的。

在workpaces中,打开Pods/RxSwift/Reactive.swift,在这里,先是两个类型的定义:

public struct Reactive<Base> {
    /// Base object to extend.
    public let base: Base

    /// Creates extensions with base object.
    ///
    /// - parameter base: Base object.
    public init(_ base: Base) {
        self.base = base
    }
}

/// A type that has reactive extensions.
public protocol ReactiveCompatible {
    /// Extended type
    associatedtype CompatibleType

    /// Reactive extensions.
    static var rx: Reactive<CompatibleType>.Type { get set }

    /// Reactive extensions.
    var rx: Reactive<CompatibleType> { get set }
}

其中,Reactive<Base>可以理解为一个具备响应式能力的类,它的泛型参数Base表示要进行响应式扩展的原始类。例如:Reactive<UITextField>表示一个具备响应式能力的输入框。接下来,ReactiveCompatible为所有支持响应式扩展的类型定义了“名字空间”rx,静态版的rx表示类型自身,而类对象属性版的rx则表示一个具体的类对象。

接下来,RxCocoa为ReactiveCompatible提供了一个默认的实现:

extension ReactiveCompatible {
    /// Reactive extensions.
    public static var rx: Reactive<Self>.Type {
        get {
            return Reactive<Self>.self
        }
        set {
            // this enables using Reactive to "mutate" base type
        }
    }

    /// Reactive extensions.
    public var rx: Reactive<Self> {
        get {
            return Reactive(self)
        }
        set {
            // this enables using Reactive to "mutate" base object
        }
    }
}

可以看到,这个实现正是我们刚才描述过的两个版本rx的功能。然后,在这个文件最后,我们可以发现下面的代码:

import class Foundation.NSObject

/// Extend NSObject with `rx` proxy.
extension NSObject: ReactiveCompatible { }

看到这里,一切就都真相大白了。实际上,所有NSObject的派生类在RxCocoa都已经自带了两个版本的rx属性。我们无需做任何额外的事情。唯一要做的,就是让“对象版本”的rx可以访问一开始我们设计的didUpdateLocations方法就好了。

有了这个思路之后,我们继续添加下面的代码:

extension Reactive where Base: CLLocationManager {
    var delegate: CLLocationManagerDelegateProxy {
        return CLLocationManagerDelegateProxy.proxy(for: base)
    }
}

由于我们一开始,让CLLocationManager遵从了HasDelegate,因此在这里,我们要定义另外一个约束delegate,它表示用于“代理请求”的对象,而这个对象,当然就是我们自己创建的CLLocationManagerDelegateProxy。唯一需要注意的,就是绝对不要手工调用init方法创建proxy delegate对象,而始终要通过proxy方法返回,记住这点就好了。

定义好delegate之后,我们继续在extension Reactive中实现希望的方法:

extension Reactive where Base: CLLocationManager {
    ///...

    var didUpdateLocations: Observable<[CLLocation]> {
        let sel = #selector
            CLLocationManagerDelegate.locationManager(_:didUpdateLocations:))

        return delegate.methodInvoked(sel).map {
            parameters in parameters[1] as! [CLLocation]
        }
    }
}

可以看到,形式上,我们只是通过delegate调用了原生的didUpdateLocations。这里,methodInvoked会返回一个Observable<[Any]>,其中[Any]表示原生的delegate方法带有的所有参数,因此,parameters[1]就表示之前我们使用的[CLLocation]。为了方便在代码中使用,我们对这个Observable进行了一次map。

完整代码如下: 整理了一下

import UIKit
import RxSwift
import RxCocoa
import CoreLocation

extension CLLocationManager: HasDelegate {
    public typealias Delegate = CLLocationManagerDelegate
}

class CLLocationManagerDelegateProxy:
    DelegateProxy<CLLocationManager, CLLocationManagerDelegate>,
    DelegateProxyType,
    CLLocationManagerDelegate {
    weak private(set) var locationManager: CLLocationManager?
    
    init(locationManager: ParentObject) {
        self.locationManager = locationManager
        super.init(parentObject: locationManager, delegateProxy: CLLocationManagerDelegateProxy.self)
    }
    
    static func registerKnownImplementations() {
        self.register { CLLocationManagerDelegateProxy(locationManager: $0) }
    }
}

extension Reactive where Base: CLLocationManager {
    var delegate: CLLocationManagerDelegateProxy {
        return CLLocationManagerDelegateProxy.proxy(for: base)
    }
    
    var didUpdateLocations: Observable<[CLLocation]> {
        let sel = #selector(CLLocationManagerDelegate.locationManager(_:didUpdateLocations:))
        
        return delegate.methodInvoked(sel).map {
            parameters in parameters[1] as! [CLLocation]
        }
    }
}
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 204,921评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 87,635评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 151,393评论 0 338
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,836评论 1 277
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,833评论 5 368
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,685评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,043评论 3 399
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,694评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 42,671评论 1 300
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,670评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,779评论 1 332
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,424评论 4 321
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,027评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,984评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,214评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,108评论 2 351
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,517评论 2 343

推荐阅读更多精彩内容

  • RxSwift_v1.0笔记——13 Intermediate RxCocoa 这章将学习一些高级的RxCocoa...
    大灰很阅读 646评论 1 1
  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,597评论 18 139
  • 国家电网公司企业标准(Q/GDW)- 面向对象的用电信息数据交换协议 - 报批稿:20170802 前言: 排版 ...
    庭说阅读 10,864评论 6 13
  • 0.前言 上一节讲了鼠标事件,现在来说说他的“兄弟”——键盘事件。 1.键盘事件 keydown:按下任意按键触发...
    紫荆峰阅读 530评论 0 0
  • 释迦牟尼说:人有八苦,分别是生、老、病、死、怨憎会、爱别离、五阴炽盛、求不得。 我年轻气盛,几乎在今天之前,我未曾...
    温香软玉阅读 309评论 0 0