repeatWhen

[thanegill]

repeatWhen

Repeats an observable when another observable emits.

extension ObservableType {
    @warn_unused_result(message="http://git.io/rxs.uo")
    public func repeatWhen<O: ObservableConvertibleType>(@autoclosure notificationHandler: (() -> O)) -> Observable<E> {
        return notificationHandler()
            .asObservable()
            .flatMapLatest { _ in
                return self
            }
    }
}

Motivation for inclusion

ReactiveX/RxSwift#396

Example of use

Polling where the repetition intervals are not equal.

Could be one of the underlying operators for #15.

[fpillet]

Sounds like a reasonable proposition! Like it.

[dchohfi]

Is this going to be merged?

[fpillet]

Will gladly merge - we just need some tests to go with! Thanks for the heads up

[danlozano]

+1 for this feature.

Need it to do polling.

[freak4pc]

I'm closing this for now due to inactivity - If you have any more comments on this subject, feel free to comment or ping me directly and I'll re-open it :) Thanks !