DBot/overdrive_that_matters
DBot/overdrive_that_matters
3
1
Fork 0
Code Issues 63 Pull Requests Packages Releases Wiki Activity

forgor

Browse Source
This commit is contained in:
DBotThePony 2023-08-12 11:47:56 +07:00
parent 1afa8e3d21
commit dba7f3ad8d
Signed by: DBot
GPG Key ID: DCC23B5715498507
1 changed files with 24 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/kotlin/ru/dbotthepony/mc/otm/core/ISubscripable.kt
View File

@ -31,10 +31,12 @@ interface ISubscriptable<V> {
} }
override fun remove() { override fun remove() {
if (!isRemoved) {
isRemoved = true isRemoved = true
queue.add(this) queue.add(this)
} }
} }
}
private val subscribers = ReferenceLinkedOpenHashSet<L>(0) private val subscribers = ReferenceLinkedOpenHashSet<L>(0)
private val queue = ReferenceArraySet<L>(0) private val queue = ReferenceArraySet<L>(0)
@ -81,10 +83,12 @@ interface IFloatSubcripable : ISubscriptable<Float> {
} }
override fun remove() { override fun remove() {
if (!isRemoved) {
isRemoved = true isRemoved = true
queue.add(this) queue.add(this)
} }
} }
}
private val subscribers = ReferenceLinkedOpenHashSet<L>(0) private val subscribers = ReferenceLinkedOpenHashSet<L>(0)
private val queue = ReferenceArraySet<L>(0) private val queue = ReferenceArraySet<L>(0)
@ -118,10 +122,12 @@ interface IDoubleSubcripable : ISubscriptable<Double> {
} }
override fun remove() { override fun remove() {
if (!isRemoved) {
isRemoved = true isRemoved = true
queue.add(this) queue.add(this)
} }
} }
}
private val subscribers = ReferenceLinkedOpenHashSet<L>(0) private val subscribers = ReferenceLinkedOpenHashSet<L>(0)
private val queue = ReferenceArraySet<L>(0) private val queue = ReferenceArraySet<L>(0)
@ -155,10 +161,12 @@ interface IIntSubcripable : ISubscriptable<Int> {
} }
override fun remove() { override fun remove() {
if (!isRemoved) {
isRemoved = true isRemoved = true
queue.add(this) queue.add(this)
} }
} }
}
private val subscribers = ReferenceLinkedOpenHashSet<L>(0) private val subscribers = ReferenceLinkedOpenHashSet<L>(0)
private val queue = ReferenceArraySet<L>(0) private val queue = ReferenceArraySet<L>(0)
@ -192,10 +200,12 @@ interface ILongSubcripable : ISubscriptable<Long> {
} }
override fun remove() { override fun remove() {
if (!isRemoved) {
isRemoved = true isRemoved = true
queue.add(this) queue.add(this)
} }
} }
}
private val subscribers = ReferenceLinkedOpenHashSet<L>(0) private val subscribers = ReferenceLinkedOpenHashSet<L>(0)
private val queue = ReferenceArraySet<L>(0) private val queue = ReferenceArraySet<L>(0)
@ -229,10 +239,12 @@ interface IBooleanSubscriptable : ISubscriptable<Boolean> {
} }
override fun remove() { override fun remove() {
if (!isRemoved) {
isRemoved = true isRemoved = true
queue.add(this) queue.add(this)
} }
} }
}
private val subscribers = ReferenceLinkedOpenHashSet<L>(0) private val subscribers = ReferenceLinkedOpenHashSet<L>(0)
private val queue = ReferenceArraySet<L>(0) private val queue = ReferenceArraySet<L>(0)