Saik0s
6/30/2015 - 4:30 AM

Alamofire and RxSwift

Alamofire and RxSwift

let rx_request = Observable<Value>.create { (observer) -> Disposable in
            let requestReference = Alamofire.request(.POST, url, parameters: payload)
                .responseJSON(completionHandler: { (response) in
                    if let value = response.result.value {
                        observer.onNext(value)
                        observer.onCompleted()
                    }else if let error = response.result.error {
                        observer.onError(error)
                    }
                })
            return AnonymousDisposable {
                requestReference.cancel()
            }
        }