iOS开发资源iOS开发ReactiveCocoa精选iOS学习

ReactiveCocoa 4上手实践1:创建自定义信号

2016-08-17  本文已影响1261人  没故事的卓同学

随着Swift引入了类型安全的特性(泛型、类型推断),在RAC 3.0+后的使用与OC的RAC 2.5已经有了很大的不同。
RAC 4 与 2.5信号的一个最大的区别就是强制区分出了热信号和冷信号。在2.5中无论冷热的信号都是RACSignal,在4.0+后热信号由Signal表示,冷信号由SignalProducer表示。具体的了解可以参照我之前翻译的一篇官方文档:《ReactiveCocoa 4 文档翻译:框架组成介绍》

创建热信号:Signal

直接看下官方playground里的代码:

    let (signal, observer) = Signal<Int, NoError>.pipe()

    let subscriber1 = Observer<Int, NoError>(next: { print("Subscriber 1 received \($0)") } )
    let subscriber2 = Observer<Int, NoError>(next: { print("Subscriber 2 received \($0)") } )

    signal.observe(subscriber1)

    //只有subscriber1收到了数据10
    observer.sendNext(10)

    // subscriber2也订阅了信号
    signal.observe(subscriber2)

    //subscriber1,subscriber2都收到了20
    observer.sendNext(20)

假设这里是要创建一个热信号,那么用的是Signal下的静态方法:pipe()。
这个方法的泛型参数有两个:第一个表示信号里带的value的类型,第二个参数表示发生failed事件时,带的error的类型。返回值是是一个tuple,第一个值是创建的signal,第二个是用来手动控制发送事件的observer。

接着创建了两个订阅者。订阅者Observer是一个结构体,两个泛型参数和Signal一样,表示next事件和failed事件中值的类型。
Observer可以订阅四种事件,初始化时可以传入对应的闭包对响应的事件做处理。这里直接贴出Observer的初始化源码:

public init(failed: (Error -> ())? = nil, completed: (() -> ())? = nil, interrupted: (() -> ())? = nil, next: (Value -> ())? = nil) {
        self.init { event in
            switch event {
            case let .Next(value):
                next?(value)

            case let .Failed(error):
                failed?(error)

            case .Completed:
                completed?()

            case .Interrupted:
                interrupted?()
            }
        }
    }

因为四种事件都是可选的闭包,并且带了默认值,所以初始化时要注意自己需要处理几种事件,根据参数名传入对应的闭包。前面的demo中只处理next事件。

然后可以用pipe()返回的信号的对应的observer来发送事件。在前面示例中<code> observer.sendNext(10)</code>发送了一个next事件。也可以发送Failed、Completed、Interrupted事件。

创建冷信号:SignalProducer

SignalProducer的信号行为是冷信号,即每个订阅者订阅的时候都会观察到相同的所有发出的事件。Signal是热信号,只会接收到订阅后发出的事件。
直接看下官方playground里的代码:

   let producer = SignalProducer<Int, NoError> { observer, disposable in
        observer.sendNext(1)
        observer.sendNext(2)
    }

    let subscriber1 = Observer<Int, NoError>(next: { print("Subscriber 1 received \($0)") })
    let subscriber2 = Observer<Int, NoError>(next: { print("Subscriber 2 received \($0)") })

    producer.start(subscriber1)

    // subscriber1,subscriber2都会收到发出的1,2的值
    producer.start(subscriber2)

SignalProducer初始化的泛型参数和signal一样,但是只返回一个SignalProducer对象,observer做作为初始化闭包中的一个参数,和2.5中RACSignal初始化函数类似。
注意SignalProducer添加订阅者的方法与Signal不同,使用的是start()方法。这样的语义也更明白一些。

empty信号

一个empty信号指马上就发送completed事件,没有任何其他值。

    let emptySignal = Signal<Int, NoError>.empty

    let emptyProducer = SignalProducer<Int, NoError>.empty

都是调用一个静态的合成属性empty。

        public static var empty: Signal {
        return self.init { observer in
            observer.sendCompleted()
            return nil
        }
    }

其实实现也很简单,就是初始化后马上发送一个完成的事件
empty的一个使用场景是作为一个高阶信号的value,有时一个产生信号的信号,里面这个信号的值可能并不重要,value就会放一个empty信号

never信号

never信号是一个不发送任何事件的信号。

    let neverSignal = Signal<Int, NoError>.never
    let neverProducer = SignalProducer<Int, NoError>.never

这个的实现也很简答,就是初始化以后什么都不做。

    public static var never: SignalProducer {
        return self.init { _ in return }
    }

never通常也是使用在高阶函数的操作里,可以用来表示一个不会结束的信号。

欢迎关注我的微博:@没故事的卓同学

上一篇下一篇

猜你喜欢

热点阅读