RxSwift教程 1 - 理解Observable & Observer

声明: 部分资料摘自 http://www.jianshu.com/p/431f645cb805http://www.codertian.com/2016/12/01/RxSwift-ru-keng-ji-learn-the-difficulty

ObserverType: Supports push-style iteration over an observable sequence. ObserverType是观察者Observer需要遵从的协议

/// Supports push-style iteration over an observable sequence.
public protocol ObserverType {
    /// The type of elements in sequence that observer can observe.
    associatedtype E

    /// Notify observer about sequence event.
    ///
    /// - parameter event: Event that occured.
    func on(_ event: Event<E>)
}

ObservableType: Represents a push style sequence。ObservableType是Observable需要遵从的协议。

/// Represents a push style sequence.
public protocol ObservableType : ObservableConvertibleType {
    /// Type of elements in sequence.
    associatedtype E
    
    func subscribe<O: ObserverType>(_ observer: O) -> Disposable where O.E == E
   ...
}

Observable是一种像信号一样的序列,而信号就需要有人监听这些信号。ObservableType协议中定义的subscribe函数就是一种简便的订阅信号的一种方法。这里的subscribe函数就是把消息发给观察者

extension ObservableType {

    /**
    Creates new subscription and sends elements to observer.
    
    In this form it's equivalent to `subscribe` method, but it communicates intent better, and enables
    writing more consistent binding code.
    
    - parameter observer: Observer that receives events.
    - returns: Disposable object that can be used to unsubscribe the observer.
    */
    public func bindTo<O: ObserverType where O.E == E>(_ observer: O) -> Disposable
    
    /**
        Creates new subscription and sends elements to variable.
    
        In case error occurs in debug mode, `fatalError` will be raised.
        In case error occurs in release mode, `error` will be logged.
    
        - parameter variable: Target variable for sequence elements.
        - returns: Disposable object that can be used to unsubscribe the observer.
        */
    public func bindTo(_ variable: RxSwift.Variable<Self.E>) -> Disposable

    ...

bindTo是ObservableType协议的扩展方法,bindTo等同于subscribe,但依RxCocoa中所说的,bindTo的内在实现更好,并且bindTo这个名称也很直观,所以当引入了RxCocoa这个framework后一般我都是用bindTo来实现UI的订阅。

  • bindTo其中一个用的比较多的重载方法bindTo<O: ObserverType where O.E == E>(_ observer: O) -> Disposable,这个方法有一个参数,从方法泛型的声明中可以得知,参数的类型为一个观察者类型,且这个观察者能够接受到的事件流元素的类型要跟被观察者的一样(O.E == E)。这个方法意图就是将一个被观察者与一个指定的观察者进行绑定,被观察者事件流中发出的所有事件元素都会让观察者接收。
    在MVVM架构模式中,此方法主要用于视图(View)层跟视图模型(ViewModel)层或视图层跟视图层的绑定,例如:
    <pre>
    textField.rx.text
    .bindTo(label.rx.text)
    .disposed(by: disposeBag)
    </pre>
  • UITextField的rx.text的属性类型是ControlProperty,不仅是观察者类型,还是被观察者类型:
struct ControlProperty<PropertyType> : ControlPropertyType
...
protocol ControlPropertyType: ObservableType, ObserverType
> * UILabel中的`rx.text`的属性类型是**`UIBindingObserver`**, 只是单纯的观察者类型。
> 
```swift
class UIBindingObserver<UIElementType, Value> : ObserverType where UIElementType: AnyObject {
    public typealias E = Value
    weak var UIElement: UIElementType?
>    
    /// Initializes `ViewBindingObserver` using
    public init(UIElement: UIElementType, binding: @escaping (UIElementType, Value) -> Void) 
   ...
}
  • UIBindingObserver是一个类,他的初始化方法中,有两个参数,第一个参数是要被绑定的视图的实例,第二个参数是一个闭包,闭包参数是被绑定了的视图本身,和一个由绑定的被观察者中所发射出来的事件元素。
    在RxCocoa框架中,UILable中的text属性是这样实现的:
public struct Reactive<Base> {
     /// Base object to extend.
    public let base: Base
    ...
}
>
extension Reactive where Base: UILabel {
>
    /// Bindable sink for `text` property.
    public var text: UIBindingObserver<Base, String?> {
        return UIBindingObserver(UIElement: self.base) { label, text in
            label.text = text
        }
    }
   ...
  • UIBindingObserver这个东西很有用的,可以用来创建我们自己的监听者。因为有时候RxCocoa给的扩展不够我们使用,比如一个UITextField有个isEnabled属性,我想把这个isEnabled变为一个observer,我们可以这样做:
extension Reactive where Base: UITextField {
    var inputEnabled: UIBindingObserver<Base, Bool> {
        return UIBindingObserver(UIElement: self.base) { textField, enabled in
            textField.isEnabled = enabled
        }
    }
}
// 当textField1输入的字符长度大于3时, textField2的输入框变成激活的。
textField1.rx.text
    .orEmpty    //Transforms ControlProperty of type `String?` into ControlProperty of type `String`.
    .map{ $0.characters.count > 3 }
    .bindTo(textField2.rx.inputEnabled)
    .disposed(by: disposeBag)
  • bindTo的另外一个用得比较多的重载方法是:bindTo(_ variable: RxSwift.Variable<Self.E>) -> Disposable,这个方法将一个被观察者与一个Variable(变量)绑定在一起,这个变量的元素类型跟被观察者的事件元素类型一致。此方法作用就是把从被观察者事件流中发射出的事件元素存入变量中。
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 204,590评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 86,808评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 151,151评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,779评论 1 277
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,773评论 5 367
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,656评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,022评论 3 398
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,678评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 41,038评论 1 299
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,659评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,756评论 1 330
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,411评论 4 321
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,005评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,973评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,203评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,053评论 2 350
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,495评论 2 343

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,596评论 18 139
  • 本章将向你介绍另一个框架,它是原生RxSwift库的一部分:RxCocoa。 RxCocoa全平台通用。每个平台有...
    大灰很阅读 857评论 3 2
  • 前言 在之前用Objective-C语言做项目的时候,我习惯性的会利用MVVM模式去架构项目,在框架Reactiv...
    Tangentw阅读 21,160评论 32 123
  • Android 自定义View的各种姿势1 Activity的显示之ViewRootImpl详解 Activity...
    passiontim阅读 171,442评论 25 707
  • 陌生人的爱,来得不那么理所当然,才显得那么滴水难得,周末闲余,写写我人生中的第一位贵人。 我已经不记得娟姨是什么时...
    阿拉半仙阅读 502评论 4 2