Swift-ReactiveCocoa3.0(二)SignalProducer

前端之家收集整理的这篇文章主要介绍了Swift-ReactiveCocoa3.0(二)SignalProducer前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。

接者上一篇,这里介绍SignalProducer。因为本人也刚接触ReactiveCocoa,不太明白为什么要有Signal和SignalProducer,但其实区别还是很大的。同时更新会有点慢,辛苦各位看官了。

SignalProducer:

  • 初始化
  1. SignalProducer<T,E: ErrorType> //跟Signal一样初始化需要带两个范型
  1. public init(value: T) //根据指定的值初始化,订阅时马上sendNext和sendCompleted
  1. public init(error: E)//根据错误初始化,订阅时马上sendError
  1. public init(_ startHandler: (Signal<T,E>.Observer,CompositeDisposable) -> ()) //常用,根据带有一个参数为observer类型,另一个为disposable类型的函数块初始化,订阅时执行该函数函数内需要sendNextsendCompletedsendError
  • buffer:
  1. public static func buffer(_ capacity: Int = Int.max) -> (SignalProducer,Signal<T,E>.Observer)
  2. //创建SignalProducer和Observer,并根据capacity的数量缓存每次发送的事件Event,每次订阅都重新发送所有事件
  3. /* 不知道有没有理解错,总之不知道有什么用,如果capacity为1就相当于Signal的pipe */
  • startWithSignal:
  1. public func startWithSignal(@noescape setUp: (Signal<T,E>,Disposable) -> ()) //

开始当前信号之前先执行函数块,之后当signalProducer发送的所有事件都会同步发送到signal,说起来难以理解,上代码

  1. let signalProducer = SignalProducer<String,NSError> { observer,disposable in
  2. sendNext(observer,"from signalProducer")
  3. sendNext(observer,"from signalProducer 2")
  4. sendCompleted(observer)
  5. }
  6.  
  7. signalProducer
  8. |> startWithSignal { signal,disposable in
  9. signal.observe(next: { println($0) })
  10. }

start后执行首先startWithSignal的函数订阅事件,再执行startHandler,发送两次next:,startWithSignal内的signal能收到两次事件并打印
注:如果startWithSignal的disposable被disposed了,就不会执行startHandler

  1. from signalProducer
  2. from signalProducer2
  • lift
  1. public func lift<U, F>(transform: Signal<T, E> -> Signal<U, F>) -> SignalProducer<U, F>
  2. SignalProducertransform转换出新的Producer,如filtermap
  • concat
  1. public func concat<T,E>(next: SignalProducer<T,E>) -> SignalProducer<T,E> -> SignalProducer<T,E>

待续。。。。。。。。。。。

猜你在找的Swift相关文章