前面介紹了信號(hào)，這里介紹一個(gè)信號(hào)發(fā)生器SignalProducer。關(guān)于信號(hào)發(fā)生器的圖例可參考自ReactiveCocoa 4 圖解之六——信號(hào)發(fā)生器（SignalProducer）。

冷信號(hào)
為什么稱SignalProducer為冷信號(hào)，看下面例子：

let producer = SignalProducer<String, NoError>.init { (observer, _) in
    print("新的訂閱，啟動(dòng)操作")
    observer.send(value: "Hello")
    observer.send(value: "World")
}

let subscriber1 = Observer<String, NoError>(value: { print("觀察者1接收到值 \($0)") })
let subscriber2 = Observer<String, NoError>(value: { print("觀察者2接收到值 \($0)") })

print("觀察者1訂閱信號(hào)發(fā)生器")
producer.start(subscriber1)

print("觀察者2訂閱信號(hào)發(fā)生器")
producer.start(subscriber2)
//注意：發(fā)生器將再次啟動(dòng)工作

打印結(jié)果：
觀察者1訂閱信號(hào)發(fā)生器 新的訂閱，啟動(dòng)操作 觀察者1接收到值 Hello 觀察者1接收到值 World 觀察者2訂閱信號(hào)發(fā)生器 新的訂閱，啟動(dòng)操作 觀察者2接收到值 Hello 觀察者2接收到值 World
所以稱SignalProducer是冷信號(hào)，任何一個(gè)訂閱者/觀察者都不會(huì)錯(cuò)過任何事件。start方法有關(guān)聯(lián)一個(gè)觀察者并激活信號(hào)的功能。

SignalProducer.empty

let emptyProducer = SignalProducer<String, NoError>.empty
let observer = Observer<String, NoError>.init(value:{ _ in print("打印值") },
                                      failed: { _ in print("失敗調(diào)用") },
                                      completed:  { _ in print("完成調(diào)用") },
                                      interrupted:{ _ in print("阻斷調(diào)用") })

emptyProducer.start(observer)

打印結(jié)果：
完成調(diào)用
注意：這里打印的是“完成調(diào)用”， 而Signal調(diào)用的是interrupted?？赡苁菫榱藚^(qū)分Signal是有時(shí)序的，SignalProducer是沒有時(shí)序的。

SignalProducer.never

會(huì)返回一個(gè)什么都不會(huì)發(fā)送信號(hào)的生成器，同上。

buffer

創(chuàng)建一個(gè)時(shí)間隊(duì)列可以回放已經(jīng)發(fā)送的事件 在5.0已移除API

startWithXXX

如startWithSignal， 返回信號(hào)開始發(fā)送的事件

print("-------------------startWithSignal-------------------")
var v1: String?

SignalProducer<String, NoError>.init(value: "Hello")
    .on(value: { (text) in
        v1 = text
    })
    .startWithSignal { (signal, disposable) in
        print(signal)
        print(v1)   //nil
    }
print(v1)


print("-------------------startWithValues-------------------")
SignalProducer<String, NoError>.init(value: "Hello")
    .startWithValues { (value) in
        print(value)
    }

打印結(jié)果：
-------------------startWithSignal------------------- ReactiveSwift.Signal<Swift.String, Result.NoError> nil Optional("Hello") -------------------startWithValues------------------- Hello
總結(jié)起來：startWithCompleted、startWithFailed、startWithInterrupted同startWithValues，只不過只能接受相應(yīng)的事件

lift

var word = ""
let transform: (Signal<String, NoError>) -> Signal<String, NoError> = { signal in
    word = "Hello"
    return signal
}

SignalProducer<String, NoError>.init(value: "").lift(transform).startWithValues { (_) in
    print(word)
}

會(huì)打?。?code>Hello

這個(gè)個(gè)人覺得較難理解，“提起”對(duì)信號(hào)發(fā)生器進(jìn)行操作，可理解為所有的原函數(shù)都是通過lift去實(shí)現(xiàn)的，接用中間信號(hào)來實(shí)現(xiàn)一系列的信號(hào)變換。

map

匹配值轉(zhuǎn)換為新的值

mapError

把收到的error轉(zhuǎn)換為新的Error

filter

過濾不符合條件的值

take

去前幾次的值

以上都和熱信號(hào)相關(guān)API使用類似。

observeOn

最后在介紹一個(gè)observeOn, 即在指定的調(diào)度器上分發(fā)事件

let baseProducer = SignalProducer<String, NoError>.init(values: ["Hello", "Nice", "to", "meet", "you"])
let completion = {
    print("是主線程嗎？\(Thread.current.isMainThread)")
}
//主線程
baseProducer.observe(on: QueueScheduler(qos: DispatchQoS.default, name: "test")).startWithCompleted(completion)

//非主線程
baseProducer.startWithCompleted(completion)

打印結(jié)果：
是主線程嗎？true 是主線程嗎？false

相關(guān)鏈接：
Swift 響應(yīng)式編程FRP使用RAC學(xué)習(xí)筆記1
Swift 響應(yīng)式編程FRP使用RAC學(xué)習(xí)筆記2