ios3
5/29/2018 - 1:17 PM

gistfile1.txt

 func test() -> Observable<Any>{
        return Observable.create({ (observer) -> Disposable in

            // requestJSON


            RxAlamofire.requestData(self.method, self.url, parameters: self.parameters, encoding: self.encoding, headers: self.headers)
                .subscribe({ event in
                    switch event {
                    case .next(let responce, let data):
                        do {
                            //Do THis hahahaha
                            observer.onNext(self.parse(dsd: MinimalUser.self, data: data))
                        } catch let e as RESTError {
                            observer.onError(e)
                        } catch {
                            observer.onError(error)
                        }

                    case .error(let error):
                        observer.onError(self.handleError(error: error))
                    case .completed:
                        observer.onCompleted()
                    }
                })

        })
    }
    
    func parse<T: Codable>(dsd:T.Type,data: Data) -> T{
         let jsonDecoder = JSONDecoder()
         return try! jsonDecoder.decode(dsd.self, from: data)
    }
   
    
}

public struct MinimalUser: Codable {
    public let id: Int
    public let login: String
}