Merge pull request #97 from linksplatform/feature/add_handler_state_s…

…truct Add `(Write|Read)HandlerState` struct
linksplatform · Jan 13, 2022 · 3b047f5 · 3b047f5
2 parents a4b0e12 + 6d6b351
commit 3b047f5
Show file tree

Hide file tree

Showing 2 changed files with 76 additions and 0 deletions.
diff --git a/csharp/Platform.Data/ReadHandlerState.cs b/csharp/Platform.Data/ReadHandlerState.cs
@@ -0,0 +1,37 @@
+using System.Collections.Generic;
+using Platform.Delegates;
+
+namespace Platform.Data
+{
+    public struct ReadHandlerState<TLink>
+    {
+        private readonly EqualityComparer<TLink> _equalityComparer;
+        public TLink Result;
+        public ReadHandler<TLink> Handler;
+        public TLink Continue;
+        public TLink Break;
+
+        public ReadHandlerState(TLink @continue, TLink @break, ReadHandler<TLink> handler)
+        {
+            _equalityComparer = EqualityComparer<TLink>.Default;
+            Continue = @continue;
+            Break = @break;
+            Result = @continue;
+            Handler = handler;
+        }
+
+        public void Apply(TLink result)
+        {
+            if (_equalityComparer.Equals(Break, Result))
+            {
+                return;
+            }
+            if (!_equalityComparer.Equals(Break, result))
+            {
+                return;
+            }
+            Handler = null;
+            Result = Break;
+        }
+    }
+}
diff --git a/csharp/Platform.Data/WriteHandlerState.cs b/csharp/Platform.Data/WriteHandlerState.cs
@@ -0,0 +1,39 @@
+using System.Collections.Generic;
+using Platform.Delegates;
+
+namespace Platform.Data
+{
+    public struct WriteHandlerState<TLink>
+    {
+        private readonly EqualityComparer<TLink> _equalityComparer;
+        public TLink Result;
+        public WriteHandler<TLink> Handler;
+        public TLink Continue;
+        public TLink Break;
+
+        public WriteHandlerState(TLink @continue, TLink @break, WriteHandler<TLink> handler)
+        {
+            _equalityComparer = EqualityComparer<TLink>.Default;
+            Continue = @continue;
+            Break = @break;
+            Result = @continue;
+            Handler = handler;
+        }
+
+        public void Apply(TLink result)
+        {
+            if (_equalityComparer.Equals(Break, Result))
+            {
+                return;
+            }
+            if (!_equalityComparer.Equals(Break, result))
+            {
+                return;
+            }
+            Handler = null;
+            Result = Break;
+        }
+    }
+}
+
+