Tag: Reactivekit

ReactiveKit的扩展集合

傻瓜发信号 扩展布尔 { func trueSignal(或失败:NSError)-> Signal { 保护自己else {返回Signal.failed(fail)} 返回Signal.just(true) } } 将布尔转换为故障 信号 。 2.可选信号 扩展名可选 { func valueSignal(或失败:NSError)-> Signal { 切换自我{ case .some(let value):返回Signal.just(值) 案例.none:返回Signal.failed(失败) } } 将Optional转换为故障 信号 。 3.尝试/捕获信号 func TrySignal (有趣:@escaping()throws-> T)-> Signal { 返回信号{ 做{ 让res =尝试fun() Observer.completed(with:res) }将let错误捕获为NSError { 观察者失败(错误) } 返回NonDisposable.instance } } 将try / catch转换为信号 4.不 […]

其他一些ReactiveKit扩展

在上一篇文章(ReactiveKit的扩展集合)之后,还有更多… 对信号的承诺 导入ReactiveKit 导入PromiseKit 扩展承诺 { 公共函数toSignal()-> Signal { 返回Signal { self.then {elem-> Void in Observer.completed(with:elem) } .catch {错误 rator.failed(错误为NSError) } 返回NonDisposable.instance } } } 在我正在从事的项目中,有一段时间,我们同时使用PromiseKit和ReactiveKit,此扩展对于将PromiseKit Promise转换为ReactiveKit信号非常有用,从而提供了帮助迁移的桥梁。 2.顺序信号 func serialSignals (_信号:[Signal ], 已完成:[ReactiveKit.Result ] = []) -> SafeSignal <[ReactiveKit.Result ]> { 守卫信号=信号。第一 否则{返回Signal.just(已完成)} 让newSignals = signal.count> 0吗? Array(signals [1 …]):[] 返回信号 .map {ReactiveKit.Result.success($ 0)} .flatMapError […]