We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent adc12b6 commit 1132e9fCopy full SHA for 1132e9f
src/main/kotlin/dev/slne/surf/redis/sync/set/SyncSet.kt
@@ -165,10 +165,12 @@ class SyncSet<T : Any> internal constructor(
165
removedElements.forEach { element ->
166
val elementJson = api.json.encodeToString(elementSerializer, element)
167
publishLocalDelta(Delta.Remove(elementJson))
168
- notifyListeners(listeners, SyncSetChange.Removed(element))
169
}
170
171
+ removedElements.forEach { element ->
172
+ notifyListeners(listeners, SyncSetChange.Removed(element))
173
+ }
174
return true
175
176
0 commit comments