swift RxSwift - 使用 - extension.swift

Posted 2021-05-19

struct DisposableWrapper: Disposable {
    private let disposable: Disposable
    init(disposable: Disposable) {
        self.disposable = disposable
    }
    func dispose() {
        disposable.dispose()
    }
}

public extension Observable {
    public func `do`(onDisposed: @escaping () -> ()) -> Observable {
        return Observable.using({
            return DisposableWrapper(disposable: Disposables.create(with: onDisposed))
            }, observableFactory: { _ -> Observable in
                return self
        })
    }
}