ReactiveX
Rx的Observable的本质就是一个Event Monad，即上下文（就是图文教程中包裹的盒子）为Event的一个Monad，这里的Event定义，可以对应语言的struct或者enum，包括了next、error和complete三个上下文即可。这里截取的是Swift语言的实现，map方法实现拆装箱（类似Optional，即Haskell的Maybe）
public enum Event<Element> {
/// Next element is produced.
case next(Element)
/// Sequence terminated with an error.
case error(Swift.Error)
/// Sequence completed successfully.
case completed
}
extension Event {
/// Maps sequence elements using transform. If error happens during the transform .error
/// will be returned as value
public func map<Result>(_ transform: (Element) throws -> Result) -> Event<Result> {
do {
switch self {
case let .next(element):
return .next(try transform(element))
case let .error(error):
return .error(error)
case .completed:
return .completed
}
}
catch let e {
return .error(e)
}
}
}
而Rx的subscribe方法就是一个解包，也就是Monad<Event>.map()，接收一个(Event) -> void的参数。或者使用更一般直观的三个参数onNext: (Element) -> Void、onError: (Error) -> Void、onCompleted: (Void) -> Void方法（在其他语言实践上，RxJS就是三个function参数，而RxJava为了支持Java7可以使用匿名内部类）
理论：
Monad Event <$> subscribe
示例：
let subscription = Observable<Int>.interval(0.3)
.subscribe { event in
print(event) // unwraped event
}
let cancel = searchWikipedia("me")
.subscribe(onNext: { results in
print(results)
}, onError: { error in
print(error)
})
Rx的Operator是Functor，也就是说(Event) -> Event，因此可以通过Monad不断bind你想要的组合子，直到最终符合UI控件需要的数据
理论：
Monad Event >>= map >>= concat >>= filter >>= map <$> subscribe
示例：
let subscription = primeTextField.rx.text // Observable<String>
.map { WolframAlphaIsPrime(Int($0) ?? 0) } // Observable<Observable<Prime>>
.concat() // Observable<Prime>
.filter { $0.isPrime } // Observable<Prime>
.map { $0.intValue } // Observable<Int>
Promise / Future
Promise本质上也是一个Monad，包裹的上下文就是resolve和reject。
你可能反驳说Promise.then(f)中的f，可以是value => value，而并不是一个被Promise包裹的类型啊。但是实际上，由于JavaScript类型的动态性，Promise.then中直接返回value类型是个语法糖罢了，实际上会处理为value => Promise.resolve(value)
Promise.resolve(1)
.then(v => v+1) //便捷写法罢了，返回的是resolved状态的Promise对象
.then(v => Promise.resolve(v+1)) //完整写法
.then(v => Promise.reject('error ' + v)) //想要返回rejected状态，无便捷方法
.catch(e => console.log(e)) // error 3
原理：
Monad Promise >>= then >>= then >>= catch >>= then
示例：
Promise.resolve(1)
.then(v => {
return v + 1; // 1
}.then(v => {
throw new Error('error'); //reject
}.catch(e => {
console.log(e); // error
return Promise.resolve(0);
}.then(v => {
console.log('end', v); // end 0
}
https://dreampiggy.com/2016/11/17/FRP简介—ReactiveCocoa、RxSwift、Bacon以及背后的Functional/