可在地图上观察以检测何时添加、更新或删除条目

Question

我有一张地图，在我的例子中是ConcurrentHashMap<String, Device>，当在 websocket 上接收到一些事件时它正在更新。我想在这个地图上实现一个 observable，以了解何时添加、更新或删除条目。我尝试使用ObservableProperty，但地图更改时没有调用任何方法。

var deviceCache : ConcurrentHashMap<String, Device> by MyObservable(ConcurrentHashMap())

 class MyObservable<T, V>(initialValue: ConcurrentHashMap<T, V>) : ObservableProperty<ConcurrentHashMap<T, V>>(initialValue) {
override fun afterChange(property: KProperty<*>, oldValue: ConcurrentHashMap<T, V>, newValue: ConcurrentHashMap<T, V>) {
  super.afterChange(property, oldValue, newValue)
  log.e("new value is $newValue")
}

override fun beforeChange(property: KProperty<*>, oldValue: ConcurrentHashMap<T, V>, newValue: ConcurrentHashMap<T, V>): Boolean {
  log.e("beforeChange called")
  return super.beforeChange(property, oldValue, newValue)
}

}

谁能帮我解决这个问题？

Answer 1

问题是Map 不是属性，你不能这样使用属性委托。你要做的就是为Map 写一个装饰器，如下所示：

class ObservableMap<K, V>(private val map: MutableMap<K, V>) : MutableMap<K, V> by map {

    override fun put(key: K, value: V): V? {
        TODO("not implemented")
    }

    override fun putAll(from: Map<out K, V>) {
        TODO("not implemented")
    }

    override fun remove(key: K): V? {
        TODO("not implemented")
    }

}

这里我们将所有操作委托给支持map，您只需在上述方法中添加/删除时实现您的逻辑。

我不确定您所说的 update 是什么意思，但如果您的意思是“地图中的某个值被覆盖”，那么您可以在 put 中处理它。

你可以像这样使用ObservableMap：

val map = ObservableMap(ConcurrentHashMap<String, String>())

请注意，如果您想支持ConcurrentHashMap 的操作，您还需要为AbstractMap<K,V> 和ConcurrentMap<K,V> 添加overrides，因为它们添加了一些您可能想要跟踪的新操作。上面的代码只是一个例子。