kscience/dataforge-core
8
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases 12 Wiki Activity

Add force-invalidate to ObservableMeta

Browse Source
This commit is contained in:
Alexander Nozik 2021-08-07 13:59:19 +03:00
parent 67554a8c98
commit b968d735ce
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
dataforge-meta/src/commonMain/kotlin/space/kscience/dataforge/meta/ObservableMeta.kt
View File

@ -24,6 +24,11 @@ public interface ObservableMeta : Meta {
* Remove all listeners belonging to given owner * Remove all listeners belonging to given owner
*/ */
public fun removeListener(owner: Any?) public fun removeListener(owner: Any?)
/**
* Force-send invalidation signal for given name to all listeners
*/
public fun invalidate(name: Name)
} }
/** /**
@ -37,7 +42,7 @@ private class ObservableMetaWrapper(
private val listeners = HashSet<MetaListener>() private val listeners = HashSet<MetaListener>()
private fun changed(name: Name) { override fun invalidate(name: Name) {
listeners.forEach { it.callback(this, name) } listeners.forEach { it.callback(this, name) }
} }
@ -60,7 +65,7 @@ private class ObservableMetaWrapper(
get() = origin.value get() = origin.value
set(value) { set(value) {
origin.value = value origin.value = value
changed(Name.EMPTY) invalidate(Name.EMPTY)
} }
override fun getOrCreate(name: Name): ObservableMutableMeta = override fun getOrCreate(name: Name): ObservableMutableMeta =
@ -78,7 +83,7 @@ private class ObservableMetaWrapper(
} }
} }
if (oldMeta != node) { if (oldMeta != node) {
changed(name) invalidate(name)
} }
} }