Как использовать flatMapLatest на драйвере с помощью RxSwift - PullRequest
Новая
       49

Как использовать flatMapLatest на драйвере с помощью RxSwift

0 голосов
/ 09 февраля 2019

Я пытаюсь получить некоторые данные из сети всякий раз, когда меняется местоположение моего пользователя.

struct CityService {
  private init() {}

  static let shared = CityService()

  lazy var nearbyCities: Driver<[City]> = {
    return GeolocationService.instance.location
      .flatMapLatest({ coordinate in
        let location = CLLocation(latitude: coordinate.latitude, longitude: coordinate.longitude)
        return CityService.shared.fetchNearbyCitiesFor(location)
      }).asDriver(onErrorJustReturn: [])
  }()

  func fetchNearbyCitiesFor(_ location: CLLocation) -> Observable<[City]> {
    return Observable.create { observer in
      let disposable = Disposables.create()

      // Mock a fetch from the network:
      let cities = [City(name: "Amsterdam"), City(name: "Berlin")]
      observer.onNext(cities)
      observer.on(.completed)

      return disposable
    }
  }
}

class GeolocationService {
  static let instance = GeolocationService()
  private (set) var location: Driver<CLLocationCoordinate2D>
}
// from: https://github.com/ReactiveX/RxSwift/blob/master/RxExample/RxExample/Services/GeolocationService.swift

struct City {
  let name: String
}

Однако, это не компилируется из-за: 

Cannot convert value of type 'SharedSequence<DriverSharingStrategy, [Any]>' to specified type 'Driver<[City]>'
(aka 'SharedSequence<DriverSharingStrategy, Array<City>>')

Я также попытался добавить несколько подсказок Типа, чтобы получить лучшую ошибку: 

lazy var nearbyCities: Driver<[City]> = {
  return GeolocationService.shared.location
  .flatMapLatest({ coordinate -> Observable<[City]> in
    let location = CLLocation(latitude: coordinate.latitude, longitude: coordinate.longitude)
    let nearbyCities: Observable<[City]> = CityService.shared.fetchNearbyCitiesFor(location)
    return nearbyCities.catch
  }).asDriver(onErrorJustReturn: [City]())
}()

Но все, что мне дает, это: 

Cannot convert value of type '(_) -> Observable<[City]>' to expected argument type '(CLLocationCoordinate2D) -> SharedSequence<_, _>'

Что я здесь не так делаю?

1 Ответ

0 голосов
/ 09 февраля 2019

Вы делаете .asDriver вызов не в том месте. 

lazy var nearbyCities: Driver<[City]> = {
    return GeolocationService.instance.location
        .flatMapLatest({ (coordinate) -> Driver<[City]> in
            let location = CLLocation(latitude: coordinate.latitude, longitude: coordinate.longitude)
            return CityService.shared.fetchNearbyCitiesFor(location)
                .asDriver(onErrorJustReturn: [])
        })
}()
...