Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- static func send<T: APIRequest>(_ request: T) -> Observable<T.Response> {
- return Single.create(subscribe: { event in
- APIKit.Session.send(request) { result in
- switch result {
- case .success(let response):
- event(.success(response))
- case .failure(let error):
- event(.error(error))
- }
- }
- return Disposables.create()
- }).asObservable()
- }
- static func send<T: APIRequest>(requestVoid: T) -> Observable<Void> {
- return Single.create(subscribe: { event in
- APIKit.Session.send(requestVoid) { result in
- switch result {
- case .success(let _):
- event(.success(()))
- case .failure(let error):
- debugPrint(error.localizedDescription)
- event(.error(error))
- }
- }
- return Disposables.create()
- }).asObservable()
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement