1

我正在使用 RxSwift 和 RxRealm 并且希望能够基于谓词观察资源的变化。功能是这样的

func observe(type: String) -> Observable<[MyRealmObject]> {
  let realm = configureRealm() // 1
  let predicate = NSPredicate(format: "type = %@", type)
  let resources = realm
    .objects(MyRealmObject.self)
    .filter(predicate)
  return Observable.array(from: resources) // 2
}

但是，Realm 需要// 2在具有运行循环 AND 的线程上运行，// 1并且// 2必须在同一线程上调用。

我不能保证已经在带有运行循环的线程上调用了 observe(type: String) 函数，所以我可能必须在函数中切换到一个 - 但那样我将无法获得同步返回值了。

关于如何确保始终保证领域观察在特定运行循环上的任何想法？

更新：使用带有运行循环的自定义线程 - 但我仍然不满意

我创建了一个自定义线程，它有一个运行循环，但获取同步返回值很丑 - 正如你所看到的，我使用了 DispatchGroup 进行同步，我真的很想避免这种情况。

func observe(type: String) -> Observable<[MyRealmObject]> {
  let observableCalculation = {
    let realm = configureRealm() // 1
    let predicate = NSPredicate(format: "type = %@", type)
    let resources = realm
      .objects(MyRealmObject.self)
      .filter(predicate)
    return Observable.array(from: resources) // 2
  }

  if Thread.current == self.realmObservationThread {
    return observableCalculation()
  }

  var o: Observable<[MyRealmObject]>!
  let g = DispatchGroup()
  g.enter()
  self.realmObservationThread.runloop?.perform {
    o = observableCalculation()
    g.leave()
  }
  g.wait()
  return o
}

任何建议，将不胜感激！

4

1 回答 1

1

您真的必须通过创建可观察对象来单独观察每个数组吗？我认为最好观察Results哪个是查询的结果，而不是像这样观察每个项目。

从这里查看示例。

然后，您可以将其包装在您自己的 observable 中，并根据 Result 中的更改，然后您可以为特定对象执行回调。

于 2018-12-20T22:45:20.233 回答