Make change event async (#132)

masesgroup · Oct 22, 2023 · 04ab116 · 04ab116
1 parent 4418b8b
commit 04ab116
Showing 1 changed file with 6 additions and 8 deletions.
diff --git a/src/net/KEFCore/Storage/Internal/EntityTypeProducer.cs b/src/net/KEFCore/Storage/Internal/EntityTypeProducer.cs
@@ -290,27 +290,25 @@ public IEnumerable<ValueBuffer> ValueBuffers
     {
         get
         {
+            if (_kafkaCompactedReplicator != null) return new KNetCompactedReplicatorEnumerable(_entityType, _kafkaCompactedReplicator);
             if (_streamData != null) return _streamData;
-            if (_kafkaCompactedReplicator == null) throw new InvalidOperationException("Missing _kafkaCompactedReplicator");
-            return new KNetCompactedReplicatorEnumerable(_entityType, _kafkaCompactedReplicator);
+            throw new InvalidOperationException("Missing _kafkaCompactedReplicator or _streamData");
         }
     }
 
     private void KafkaCompactedReplicator_OnRemoteUpdate(IKNetCompactedReplicator<TKey, TValueContainer> arg1, KeyValuePair<TKey, TValueContainer> arg2)
     {
-        try
+        Task.Factory.StartNew(() =>
         {
             _onChangeEvent?.Invoke(new EntityTypeChanged(_entityType, EntityTypeChanged.ChangeKindType.Upserted, arg2.Key));
-        }
-        catch { }
+        });
     }
 
     private void KafkaCompactedReplicator_OnRemoteRemove(IKNetCompactedReplicator<TKey, TValueContainer> arg1, KeyValuePair<TKey, TValueContainer> arg2)
     {
-        try
+        Task.Factory.StartNew(() =>
         {
             _onChangeEvent?.Invoke(new EntityTypeChanged(_entityType, EntityTypeChanged.ChangeKindType.Removed, arg2.Key));
-        }
-        catch { }
+        });
     }
 }