Swift 响应式编程FRP使用RAC学习笔记2

前文已经介绍了使用RAC从代码上看上去有些简便之处，本文还是从FRP编程的基础开始——信号。

热信号

通过Siganl.pipe()创建了一个可发送String类型的信号和一个观察者

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

let subscriber1 = Observer<String, NoError>(value: { print("观察者1接收到值 \($0)") })
let subscriber2 = Observer<String, NoError>(value: { print("观察者2接收到值 \($0)") })
//观察者1订阅信号
signal.observe(subscriber1)
//发送值10 订阅者1能接收到
observer.send(value: "Hello")
//注意：此时订阅者2还不能接受到

//观察者2订阅信号
signal.observe(subscriber2)
//发送值20 这时subscriber1和subscriber2都会收到值
observer.send(value: "World")

注意：Signal没有实现发送数据的方法，它内部有一个Observer去发送数据，被pipe方法直接返回

空信号

let emptySignal = Signal<String, NoError>.empty
let observer1 = Observer<String, NoError>.init(value: { (text) in
    print("打印值")
}, failed: { (noerror) in
    print("失败调用")
}, completed:  { () in
    print("完成调用")
}, interrupted:{ () in
    print("阻断调用")
})
emptySignal.observe(observer1)

这样的空信号会直接发送一个interrupted事件

never信号

let neverSignal = Signal<String, NoError>.never
let observer2 = Observer<String, NoError>.init(value: { (text) in
    print("打印值")
}, failed: { (noerror) in
    print("失败调用")
}, completed:  { () in
    print("完成调用")
}, interrupted:{ () in
    print("阻断调用")
})
neverSignal.observe(observer2)

never信号不会发送任何事件

uniqueValues 唯一值

仅从集合中发送一次相同事件

let (signal, observer) = Signal<String, NoError>.pipe()
let subscriber = Observer<String, NoError>(value: { print("观察者接收到值 \($0)") } )

let uniqueSignal = signal.uniqueValues()
uniqueSignal.observe(subscriber)
observer.send(value: "Hello")
observer.send(value: "Swift")
observer.send(value: "World")
observer.send(value: "Hello")
observer.send(value: "Hello")
observer.send(value: "Swift")
observer.send(value: "World")

打印结果：
观察者接收到值 Hello 观察者接收到值 Swift 观察者接收到值 World
像以上这样被发送的值被保留下来，用于以后发送的时候来检查是否重复，需注意内存消耗。

map

把发送过来的值转换为新的值

let (signal, observer) = Signal<String, NoError>.pipe()
let subscriber = Observer<String, NoError>(value: { print("观察者接收到值 \($0)") } )

let mappedSignal = signal.map { (text) -> String in
    return text + "Everybody"
}
mappedSignal.observe(subscriber)
print("map后发送Hello")
observer.send(value: "Hello")

可用map在观察者接收之前做一些操作。同map的还有mapError，可以将收到的error值变成新的error值。

filter

let (signal, observer) = Signal<String, NoError>.pipe()
let subscriber = Observer<String, NoError>(value: { print("观察者接收到值 \($0)") } )
let filterSignal = signal.filter { (text) -> Bool in
    return text.hasPrefix("Hel")
}
filterSignal.observe(subscriber);
observer.send(value: "Hello")
observer.send(value: "Help")
observer.send(value: "Hi")

打印结果：
观察者接收到值 Hello 观察者接收到值 Help
可用于过滤一些值。

其余还有
gnal.skipNil()、signal.take(during:)、signal.collect()
这些也都比较简单，就不在一一测试了。

---

相关链接：Swift 响应式编程FRP使用RAC学习笔记1