所以我拥有的是一个使用 REST 端点的应用程序,但在它可以使用它之前。它必须调用一个注册端点,该端点将一个 DeviceId 分配给必须在所有后续 API 调用中使用的设备。
目前我正在使用 Moya 和 RxSwift 来链接和转换请求。
我在想我会像这样根据我的要求调用自定义操作员
self.mapRect
.waitForDeviceId()
.flatMap { [weak self] mapRect -> Single<Response> in
...
weakSelf.provider.rx.request(PCDepartmentTarget.list(coordinate: center, distance: maxDistance))
}
.map(to: [PCParkingLot].self)
.bind(to: self.parkingLotOVariable)
.disposed(by: self.disposeBag)
我认为 waitForDeviceId() 应该看起来像这样。
extension ObservableType {
func waitForDeviceId<R>() -> Observable<R> {
PCDeviceIdService.shared.deviceIdObservable.flatMap { _ -> Observable<R> in
return self
}
}
}
这显然没有编译。
您对如何实现这样的和运营商有任何想法,或者可能是一种不同的方式。先感谢您。