接者上一篇,这里介绍SignalProducer。因为本人也刚接触ReactiveCocoa,不太明白为什么要有Signal和SignalProducer,但其实区别还是很大的。同时更新会有点慢,辛苦各位看官了。
SignalProducer:
- 初始化
- SignalProducer<T,E: ErrorType> //跟Signal一样初始化需要带两个范型
- public init(value: T) //根据指定的值初始化,订阅时马上sendNext和sendCompleted
- buffer:
- startWithSignal:
- public func startWithSignal(@noescape setUp: (Signal<T,E>,Disposable) -> ()) //
开始当前信号之前先执行函数块,之后当signalProducer发送的所有事件都会同步发送到signal,说起来难以理解,上代码:
- let signalProducer = SignalProducer<String,NSError> { observer,disposable in
- sendNext(observer,"from signalProducer")
- sendNext(observer,"from signalProducer 2")
- sendCompleted(observer)
- }
-
- signalProducer
- |> startWithSignal { signal,disposable in
- signal.observe(next: { println($0) })
- }
start后执行首先startWithSignal的函数块订阅事件,再执行startHandler,发送两次next:,startWithSignal内的signal能收到两次事件并打印
注:如果startWithSignal的disposable被disposed了,就不会执行startHandler
- from signalProducer
- from signalProducer2
- lift
- public func lift<U, F>(transform: Signal<T, E> -> Signal<U, F>) -> SignalProducer<U, F>
- 将SignalProducer按transform转换出新的Producer,如filter、map。
- concat
- public func concat<T,E>(next: SignalProducer<T,E>) -> SignalProducer<T,E> -> SignalProducer<T,E>
待续。。。。。。。。。。。