接者上一篇,这里介绍SignalProducer。因为本人也刚接触ReactiveCocoa,不太明白为什么要有Signal和SignalProducer,但其实区别还是很大的。同时更新会有点慢,辛苦各位看官了。
SignalProducer:
@H_
404_9@SignalProducer<T,E: ErrorType>
@H_
404_9@
public init(
value: T) //根据指定的值初始化,
订阅时马上sendNext和sendCompleted
@H_
404_9@
public init(error: E)//根据
错误初始化,
订阅时马上sendError
@H_
404_9@public init
(_ startHandler: (Signal<T,E>.Observer,CompositeDisposable) -> ()) //常用,根据带有一个参数为observer类型,另一个为disposable类型的函数块初始化,订阅时执行该函数,函数内需要sendNext、sendCompleted、sendError
@H_
404_9@
public static func
buffer(_ capacity: Int = Int.max) -> (SignalProducer,Signal<T,E>.Observer)
@H_
404_9@public func startWithSignal
(@noescape setUp: (Signal<T,E>,Disposable) -> ()) //
开始当前信号之前先执行函数块,之后当signalProducer发送的所有事件都会同步发送到signal,说起来难以理解,上代码:
@H_
404_9@
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
@H_
404_9@
from signalProducer
from signalProducer2
@H_
404_9@public func lift
<U, F>(transform: Signal
<T, E> -> Signal
<U, F>) -> SignalProducer
<U, F>
将SignalProducer按transform转换出新的Producer,如filter、map。
@H_
404_9@public func concat<
T,E>(
next: SignalProducer<
T,E>) -> SignalProducer<
T,E> -> SignalProducer<
T,E>
待续。。。。。。。。。。。