extension ObservableConvertibleType {
//当被监视的序列(notifier)发出事件时,重新发送源序列
func repeatWhen<O: ObservableType>(_ notifier: O) -> Observable<E> {
return notifier.map { _ in }
.startWith(())
.flatMap { () -> Observable<E> in
self.asObservable()
}
}
}
网友评论