swift-mvi/Rx.swift at master · memtrip/swift-mvi

RxSwift ConnectableObservable missing autoconnect

• RxSwift 는 autoconnect()가 없기 때문에 직접 구현해주어야 한다.

extension ConnectableObservableType {
    func autoconnect() -> Observable<E> {
        return Observable.create { observer in
            return self.do(onSubscribe: {
                _ = self.connect()
            }).subscribe { (event: Event<Self.E>) in
                switch event {
                case .next(let value):                   
                    observer.on(.next(value))
                case .error(let error):
                    observer.on(.error(error))
                case .completed:
                    observer.on(.completed)
                }

            }
        }
    }
}

구독 공유

구독 공유