Alamofire, Rxified

DataRequest+Rx.swift

import Alamofire
import RxSwift

extension DataRequest {
    
    public func observeResponseJSON() -> Observable<Any?>  {
        
        let original = self.request!
        
        return Observable.create { observer in
            
            let req = Alamofire.request(original).responseJSON(
                queue: Schedulers.ioQueue,
                completionHandler: { response in
                    switch response.result {
                    case .success(let val):
                        observer.on(.next(val))
                        observer.on(.completed)
                    case .failure(let err):
                        observer.on(.error(err))
                    }
            })
            
            return Disposables.create { req.cancel() }
            
        }.take(1)
    }
}