重复执行某个操作序列

2018-09-17  本文已影响7人  FallPine
extension ObservableConvertibleType {
     
    //当被监视的序列(notifier)发出事件时,重新发送源序列
    func repeatWhen<O: ObservableType>(_ notifier: O) -> Observable<E> {
        return notifier.map { _ in }
            .startWith(())
            .flatMap { () -> Observable<E> in
                self.asObservable()
        }
    }
}

参考文章:Swift - RxSwift的使用详解67(重复执行某个操作序列:repeatWhen)

上一篇 下一篇

猜你喜欢

热点阅读