How to chain completables with closures in RxSwift?

user_1771537 0
Viewed 367

I would like to do something like

Completable.empty()
    .andThen { // this does not work
        // run some code
        NSLog("Now pushing objects")
        return Completable.empty // e.g. return api.pushObjects() -> Completable
    }
    .andThen(Completable.empty()) // this is working
    .andThen { // this does not work
        // do something else
        NSLog("Now pulling objects")
        return Completable.empty // e.g. return api.pullObjects() -> Completable
    }

andThen (or concat) does not allow closures as argument. The compiler complains:

Trailing closure passed to parameter of type 'Completable' (aka 'PrimitiveSequence<CompletableTrait, Never>') that does not accept a closure

My question is: How to chain completables with closures?

rx-swift
1 Answers

You don't. There is no version of andThen that takes a closure. The closest you can get to it is this:

Completable.empty()
    .andThen(Completable.create(subscribe: { observer in
        print("Now pushing objects")
        observer(.completed)
        return Disposables.create()
    }))
user_5064410
Related