extension ObservableConvertibleType {
//当被监视的序列(notifier)发出事件时,重新发送源序列
func repeatWhen<O: ObservableType>(_ notifier: O) -> Observable<E> {
return notifier.map { _ in }
.startWith(())
.flatMap { () -> Observable<E> in
self.asObservable()
}
}
}
重复执行某个操作序列
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。
相关阅读更多精彩内容
- 五月的二中校园,色彩斑斓、花香鸟语。 五月的二中校园,温情暖暖、爱意连连。 为了践行我校特色文化教育活动,...