feat: SyncSet raise event when initially synchronized

MirageNet · Oct 23, 2020 · 03f2075 · 03f2075
1 parent 9f679c5
commit 03f2075
Show file tree

Hide file tree

Showing 2 changed files with 34 additions and 0 deletions.
diff --git a/Assets/Mirror/Runtime/SyncSet.cs b/Assets/Mirror/Runtime/SyncSet.cs
@@ -150,17 +150,20 @@ public void OnDeserializeAll(NetworkReader reader)
 
             objects.Clear();
             changes.Clear();
+            OnClear?.Invoke();
 
             for (int i = 0; i < count; i++)
             {
                 T obj = reader.Read<T>();
                 objects.Add(obj);
+                OnAdd?.Invoke(obj);
             }
 
             // We will need to skip all these changes
             // the next time the list is synchronized
             // because they have already been applied
             changesAhead = (int)reader.ReadPackedUInt32();
+            OnChange?.Invoke();
         }
 
         public void OnDeserializeDelta(NetworkReader reader)

diff --git a/Assets/Tests/Editor/SyncSetTest.cs b/Assets/Tests/Editor/SyncSetTest.cs
@@ -50,6 +50,37 @@ public void TestInit()
             Assert.That(clientSyncSet, Is.EquivalentTo(new[] { "Hello", "World", "!" }));
         }
 
+        [Test]
+        public void ClearEventOnSyncAll()
+        {
+            Action callback = Substitute.For<Action>();
+            clientSyncSet.OnClear += callback;
+            SerializeAllTo(serverSyncSet, clientSyncSet);
+            callback.Received().Invoke();
+        }
+
+        [Test]
+        public void InsertEventOnSyncAll()
+        {
+            Action<string> callback = Substitute.For<Action<string>>();
+            clientSyncSet.OnAdd += callback;
+            SerializeAllTo(serverSyncSet, clientSyncSet);
+
+            callback.Received().Invoke("Hello");
+            callback.Received().Invoke("World");
+            callback.Received().Invoke("!");
+        }
+
+        [Test]
+        public void ChangeEventOnSyncAll()
+        {
+            Action callback = Substitute.For<Action>();
+            clientSyncSet.OnChange += callback;
+            SerializeAllTo(serverSyncSet, clientSyncSet);
+            callback.Received().Invoke();
+        }
+
+
         [Test]
         public void TestAdd()
         {