NWPathMonitor+Reactive.swift

import Network

extension NWPathMonitor: ReactiveCompatible {}

extension Reactive where Base == NWPathMonitor {
    func pathUpdate(on queue: DispatchQueue = .global(qos: .background)) -> Observable<NWPath> {
        return Observable.create { [weak base] observer in
            base?.pathUpdateHandler = observer.onNext
            base?.start(queue: queue)
            return Disposables.create { base?.cancel() }
        }
    }
}

NWPathMonitor(requiredInterfaceType: .cellular).rx.pathUpdate().subscribe()