import Foundation
import APIKit
import RxSwift

extension Session: ReactiveCompatible {}
extension Reactive where Base: Session {
    static func send<T: Request>(request: T) -> Observable<T.Response> {
        return Observable.create { observer in
            let task = Session.shared.send(request) { result in
                switch result {
                case .success(let response): observer.on(.next(response))
                                             observer.on(.completed)
                case .failure(let error): observer.onError(error)
                }
            }
            return Disposables.create { task?.cancel() }
        }
    }
}