Distinguish between Added and Removed (#133)

* Removed Upserted and distinguished between Added and Removed

* Removed helper

src/net/KEFCore/Storage/EntityTypeChanged.cs

@@ -42,10 +42,6 @@ public enum ChangeKindType
         /// The <see cref="Key"/> was removed
         /// </summary>
         Removed = 4,
-        /// <summary>
-        /// The <see cref="Key"/> was added or updated
-        /// </summary>
-        Upserted = Added | Updated,
     }
 
     internal EntityTypeChanged(IEntityType entityType, ChangeKindType changeKind, object key)
@@ -78,8 +74,4 @@ internal EntityTypeChanged(IEntityType entityType, ChangeKindType changeKind, ob
     /// Helper to understand if the <see cref="Key"/> was removed
     /// </summary>
     public bool KeyRemoved => ChangeKind.HasFlag(ChangeKindType.Removed);
-    /// <summary>
-    /// Helper to understand if the <see cref="Key"/> was added or updated
-    /// </summary>
-    public bool KeyUpserted => ChangeKind.HasFlag(ChangeKindType.Added) | ChangeKind.HasFlag(ChangeKindType.Updated);
 }

src/net/KEFCore/Storage/Internal/EntityTypeProducer.cs

@@ -300,7 +300,7 @@ private void KafkaCompactedReplicator_OnRemoteUpdate(IKNetCompactedReplicator<TK
     {
         Task.Factory.StartNew(() =>
         {
-            _onChangeEvent?.Invoke(new EntityTypeChanged(_entityType, EntityTypeChanged.ChangeKindType.Upserted, arg2.Key));
+            _onChangeEvent?.Invoke(new EntityTypeChanged(_entityType, arg1.ContainsKey(arg2.Key) ? EntityTypeChanged.ChangeKindType.Updated : EntityTypeChanged.ChangeKindType.Added, arg2.Key));
         });
     }