我在我的应用程序中使用 RSwift 库。我正在尝试获取用户位置以便在网络请求中发送它。要获取此位置，我需要使用 Observables，因为如果用户未授权位置，该函数必须抛出错误。
该算法是在主线程之外的另一个线程中运行的许多 Observable 的串联数组的一部分（为了不冻结 UI）。我需要在主线程中执行“获取用户位置”功能，因为如果不在主线程中执行它会崩溃并且崩溃日志是：
fatal error: Executing on backgound thread. Please use `MainScheduler.instance.schedule` to schedule work on main thread
在上面的代码中，有geolocation helper init（这是一个单例）和获取用户位置（或错误）的方法。
private var authorized: Observable<Bool?>
private var location: Observable<CLLocationCoordinate2D>
private let locationManager = CLLocationManager()
private init() {
locationManager.desiredAccuracy = LocationOptions.desiredAccuracy
authorized = Observable.just(false)
.map({ _ in CLLocationManager.authorizationStatus() })
.concat(locationManager.rx_didChangeAuthorizationStatus)
.distinctUntilChanged()
.map({ authorizedStatus in
switch authorizedStatus {
case .AuthorizedAlways, .AuthorizedWhenInUse:
return true
case .NotDetermined:
return nil
case .Restricted, .Denied:
return false
}
})
.catchErrorJustReturn(false)
location = locationManager.rx_didUpdateLocations
.filter { $0.count > 0 }
.map({ return $0.last!.coordinate })
}
func getLocation() -> Observable<Location> {
return authorized
.flatMap({ authorized -> Observable<CLLocationCoordinate2D> in
guard let authorized = authorized else {
self.locationManager.requestAlwaysAuthorization()
return Observable.empty()
}
if authorized {
self.startUpdating()
return self.location
} else {
return Observable.error(
NSError(
domain:"",
code: 0,
userInfo:nil )
)
}
})
// We just need one position updated
.take(1)
.map({ coordinate in
self.stopUpdating()
let location = Location(longitude: coordinate.longitude, latitude: coordinate.latitude, latestUpdatedDate: NSDate())
if location.isValid() {
saveLocation(location)
}
return location
})
.doOnError({ error in self.stopUpdating() })
}
我在 RXSwift 地理定位示例 ( https://github.com/ReactiveX/RxSwift/pull/429 ) 中看到了一个可以使用 Drivers 处理它的类，但我确实需要一个错误并且 Drivers 不能返回错误。
如果有人可以帮助我实现这一目标，我将不胜感激。
我已经尝试将“.observeOn(MainScheduler.instance)”添加到 2 个 observables 中，但它会冻结 UI。也许有更好的方法可以在不冻结 UI 的情况下执行此操作。
谢谢