Observable+Unbox.swift

import RxSwift
import Moya
import Unbox

public extension ObservableType where E == Response {
  public func mapObject<T: Unboxable>(type: T.Type) -> Observable<T> {
    return flatMap { response -> Observable<T> in
      return Observable.just(try response.mapObject(type: T.self))
    }
  }

  public func mapArray<T: Unboxable>(type: T.Type) -> Observable<[T]> {
    return flatMap { response -> Observable<[T]> in
      return Observable.just(try response.mapArray(type: T.self))
    }
  }
}

public extension Response {
  public func mapObject<T: Unboxable>(type: T.Type) throws -> T {
    guard let json = try mapJSON() as? UnboxableDictionary else {
      throw MoyaError.jsonMapping(self)
    }
    return try unbox(dictionary: json)
  }

  public func mapArray<T: Unboxable>(type: T.Type) throws -> [T] {
    guard let jsonArray = try mapJSON() as? [UnboxableDictionary] else {
      throw MoyaError.jsonMapping(self)
    }
    return try unbox(dictionaries: jsonArray)
  }
}