IPAPI+ReactiveKit

IPAPI+ReactiveKit.swift

//
//  IPAPI+ReactiveKit.swift
//  Created by Dmitry Shmidt on 5/25/18.
//

import IPAPI
import ReactiveKit

extension Service{
    @discardableResult open func fetch(query: String? = nil, fields: [Result.Field]? = nil, language: String? = nil) -> Signal<Service.Result, Service.Error>
    {
        return Signal { [weak self] observer in
            let task = self?.fetch(query: query, fields: fields, language: language, completion: { result, error in
                if let error = error as? Service.Error{
                    observer.failed(error)
                }else if let result = result{
                    observer.next(result)
                    observer.completed()
                }
            })
            return BlockDisposable {
                task?.cancel()
            }
        }
    }
}