观察领域的变化没有发射

Question

在我的应用程序中，我有一个自定义RealmDatabase类。它为我初始化了领域数据库。

public class RealmDatabase: Database {
    let realm: Realm
    //
    // I also provide a shared() singleton
    //
    public init(fileURL: URL) {
        let config = Realm.Configuration(fileURL: fileURL)
        Realm.Configuration.defaultConfiguration = config
        realm = try! Realm()
    }
    public func observe<T>(_ block: @escaping ((T) -> Void), for object: T.Type) where T : Storable {
        realm.objects(object).observe { (changes) in
            print("Changes: ", changes)
        }
    }
}

现在，我还写了一个名为SyncEngine的类，以便我可以开始与CloudKit同步。班级看起来像这样：

public class SyncEngine: NSObject {
    private let database: Database
    public init(database: Database) {
        self.database = database
        super.init()
    }
    public func start() {
        database.observe({ restaurant in
            print("changes!")
        }, for: Restaurant.self)
    }
}

现在，在我的AppDelegate中，我执行以下操作：

let database = RealmDatabase.shared()
let syncEngine = SyncEngine(database: database)
syncEngine.start()

问题是，我的观察者从未被触发，并且print("Changes: ", changes)永远不会印刷到控制台上。我不知道我在做什么错。有什么想法吗？

Answer 1

您在创建观察时丢弃了观察结果。要解决这个问题，您需要保留observe返回的NotificationToken。

var token: NotificationToken? 
func start() {
    token = database.observe { changes in ... }
}