RxSwift - Then

then.swift

@jamiepinkham
 public extension ObservableType {
    
    func then(closure: () -> Observable<E>?) -> Observable<E> {
        return then(closure() ?? .empty())
    }
    
    func then(@autoclosure(escaping) closure: () -> Observable<E>) -> Observable<E> {
        let next = Observable.deferred {
            return closure() ?? .empty()
        }
        
        return self
            .ignoreElements()
            .concat(next)
    }
}

@c0diq
extension ObservableType {
    public func then<U>(_ replacement: Observable<U>) -> Observable<U> {
        return Observable.create { observer in
            let observerDisposable = CompositeDisposable.init()

            let disposable = self.asObservable().subscribe { event in
                switch event {
                case let .error(error):
                    observer.onError(error)
                case .completed:
                    _ = observerDisposable.insert(replacement.subscribe(observer))
                case .next:
                    break
                }
            }
            _ = observerDisposable.insert(disposable)
            return observerDisposable
        }
    }
}

Hey. Thanks for the snippet! But what is it? - @jamiepinkham oO