1.创建信号

// 1.通过信号发生器创建(冷信号)
let producer = SignalProducer.init { (observer, _) in
print("新的订阅，启动操作")
observer.send(value: "Hello")
observer.send(value: "World")
}

let subscriber1 = Observer(value: { print("观察者1接收到值 \($0)") })
let subscriber2 = Observer(value: { print("观察者2接收到值 \($0)") })

print("观察者1订阅信号发生器")
producer.start(subscriber1)
print("观察者2订阅信号发生器")
producer.start(subscriber2)
//注意：发生器将再次启动工作

// 2.通过管道创建（热信号）
let (signalA, observerA) = Signal.pipe()
let (signalB, observerB) = Signal.pipe()
Signal.combineLatest(signalA, signalB).observeValues { (value) in
print( "收到的值\(value.0) + \(value.1)")
}
observerA.send(value: "")
//注意:如果加这个就是，发了一次信号就不能再发了
observerA.sendCompleted()
observerB.send(value: "")
observerB.sendCompleted()

//3.创建空信号
let emptySignal = Signal.empty
emptySignal.observe { (value) in

}

2.基本控件用法

//MARK:通知
private func noti() {

    NotificationCenter.default.reactive.notifications(forName: Notification.Name(rawValue: "UIKeyboardWillShowNotification"), object: nil).observeValues { (value) in

    }

    NotificationCenter.default.post(name: Notification.Name(rawValue: "name"), object: self)  
}

//MARK:KVO  
private func kvoWithRac() {

    view.reactive.values(forKeyPath: "bounds").start { \[weak self\](rect) in  
        print(self?.view ?? "")  
        print(rect)  
    }  
}

//MARK:按钮点击  
private func btnWithRAC() {

    //1.点击  
    btn.tag =  
    btn.isEnabled = true  
    btn.reactive.controlEvents(.touchUpInside).observeValues { (btn) in  
        print("点击了按钮,颜色\\(btn.tag)")  
    }  
}

//textField
textField.reactive.continuousTextValues.observeValues { (value) in

    }

3.过滤  filter

//filter作用:过滤 当text>5才会输出
textField.reactive.continuousTextValues.filter { (text) -> Bool in

        return (text?.characters.count)! >  
        }.observe({  
            text in  
            print(text)  
        })

4.转换 map

//每一次map接收到的Value事件，它就会运行closure，以closure的返回值作为Value事件发送出去。上面的代码中，我们的text的值映射成text的字符数
textField.reactive.continuousTextValues.map { (text) -> Int in
return (text?.characters.count)!
}.filter { (length) -> Bool in
return length >
}.observe { (length) in
print(length)
}

    //(改变属性)使用map与observeValues结合改变属性  
    textField.reactive.continuousTextValues  
        .map { (text) -> Int in  
            return (text?.characters.count)!  
        }  
        .map { (length) -> UIColor in  
            return length >  ? UIColor.red : UIColor.yellow  
        }  
        .observeValues { (backgroundColor) in  
            self.textField.backgroundColor = backgroundColor  
    }

5.两个信号结合使用 <~

//1.
let nameSign = textField.reactive.continuousTextValues.map { (text) -> Int in
return (text?.characters.count)!
}
let passSign = passwordtextField.reactive.continuousTextValues.map { (text) -> Int in
return (text?.characters.count)!
}
btn.reactive.isEnabled <~ Signal.combineLatest(nameSign, passSign).map({(namelength : Int, passlength : Int) -> Bool in

        return namelength >=  && passlength >  
    })

//2.

Signal.combineLatest(nameSign,passSign).observeValues { (namelength : Int, passlength : Int) in

        }

6.Scheduler(调度器)延时加载

// 主线程上延时0.3秒调用
QueueScheduler.main.schedule(after: Date.init(timeIntervalSinceNow: 0.3)) {
print("主线程调用")
}

    QueueScheduler.init().schedule(after: Date.init(timeIntervalSinceNow: 0.3)){  
        print("子线程调用")  
    }

7.迭代器

// 数组的迭代器
let array:[String] = ["name","name2"]
var arrayIterator = array.makeIterator()
while let temp = arrayIterator.next() {
print(temp)
}

    // swift 系统自带的遍历  
    array.forEach { (value) in  
        print(value)  
    }

    // 字典的迭代器  
    let dict:\[String: String\] = \["key":"name", "key1":"name1"\]  
    var dictIterator =  dict.makeIterator()  
    while let temp = dictIterator.next() {  
        print(temp)  
    }

    // swift 系统自带的遍历  
    dict.forEach { (key, value) in  
        print("\\(key) + \\(value)")  
    }

8.信号联合

func testZip() {
let (signalA, observerA) = Signal.pipe()
let (signalB, observerB) = Signal.pipe()

    Signal.zip(signalA, signalB).observeValues { (value) in  
        print(value)  
    }

    signalA.zip(with: signalB).observeValues { (value) in

    }  
    observerA.send(value: "")  
    observerA.sendCompleted()  
    observerB.send(value: "")  
    observerB.sendCompleted()  
}

9.代替delegate

.
import ReactiveCocoa
import ReactiveSwift
import Result

.let (signalTap , observerTap) = Signal.pipe()
observerTap.send(value: tap)
自定义个view
class LyContentView: UIView {

let (signalTap , observerTap) = Signal<Any, NoError>.pipe()

override init(frame: CGRect) {  
    super.init(frame: frame)

     setUI()  
}

required init?(coder aDecoder: NSCoder) {  
    fatalError("init(coder:) has not been implemented")  
}

}

extension LyContentView {
fileprivate func setUI() {
backgroundColor = UIColor.yellow

    let tap = UITapGestureRecognizer(target: self, action: #selector(self.tapClick(\_:)))  
    addGestureRecognizer(tap)  
}

//使用RAC，替代delegate，闭包  
@objc fileprivate func tapClick(\_ tap : UITapGestureRecognizer) {  
    observerTap.send(value: tap)  
}  

}
.控制器中监听
contentView.signalTap.observeValues { (value) in
print("点击了view")
}

Demo:https://github.com/zhangjie579/LyReactiveSwiftDemo