tests for enumerable/async

Author: Ledjon Behluli

src/OrleanSpaces/Tuples/Specialized/IntTuple.cs

@@ -72,7 +72,7 @@ public ReadOnlySpan<int>.Enumerator GetEnumerator() =>
 /// </summary>
 public readonly record struct IntTemplate : 
     IEquatable<IntTemplate>,
-    //IEqualityOperators<IntTemplate, IntTemplate, bool>,
+    IEqualityOperators<IntTemplate, IntTemplate, bool>,
     ISpaceTemplate<int>, 
     ISpaceMatchable<int, IntTuple>
 {

tests/OrleanSpaces.Tests/Agents/IntAgentTests.cs

@@ -332,8 +332,11 @@ public async Task Should_Enumerate()
             await agent.WriteAsync(tuple);
         }
 
-        IEnumerable<IntTuple> result = agent.Enumerate(new(enumerate, 1, 2, 3, null));
-        Assert.Equal(3, result.Count());
+        IEnumerable<IntTuple> resultAll = agent.Enumerate();
+        IEnumerable<IntTuple> resultFiltered = agent.Enumerate(new(enumerate, 1, 2, 3, null));
+
+        Assert.Equal(7, resultAll.Count());
+        Assert.Equal(3, resultFiltered.Count());
     }
 
     [Fact]
@@ -344,18 +347,34 @@ public async Task Should_EnumerateAsync()
             new(consume, 0),
             new(consume, 1),
             new(consume, 2),
-            new(consume, 3),
+            new(consume, 2),
             new(consume, 4)
         };
 
         _ = Task.Run(async () =>
         {
             int i = 1;
+
             await foreach (IntTuple tuple in agent.EnumerateAsync())
             {
                 Assert.Equal(tuples[i], tuple);
                 i++;
             }
+
+            Assert.Equal(5, i);
+        });
+
+        _ = Task.Run(async () =>
+        {
+            int i = 1;
+
+            await foreach (IntTuple tuple in agent.EnumerateAsync(new(consume, 2)))
+            {
+                Assert.Equal(tuples[i], tuple);
+                i++;
+            }
+
+            Assert.Equal(2, i);
         });
 
         int i = 0;

tests/OrleanSpaces.Tests/Agents/SpaceAgentTests.cs

@@ -332,8 +332,11 @@ public async Task Should_Enumerate()
             await agent.WriteAsync(tuple);
         }
 
-        IEnumerable<SpaceTuple> result = agent.Enumerate(new(enumerate, 1, typeof(string), typeof(float), null));
-        Assert.Equal(3, result.Count());
+        IEnumerable<SpaceTuple> resultAll = agent.Enumerate();
+        IEnumerable<SpaceTuple> resultFiltered = agent.Enumerate(new(enumerate, 1, typeof(string), typeof(float), null));
+
+        Assert.Equal(7, resultAll.Count());
+        Assert.Equal(3, resultFiltered.Count());
     }
 
     [Fact]
@@ -344,18 +347,34 @@ public async Task Should_EnumerateAsync()
             new(consume, 0),
             new(consume, 1),
             new(consume, 2),
-            new(consume, 3),
-            new(consume, 4)
+            new(consume, 2),
+            new(consume, 3)
         };
 
         _ = Task.Run(async () =>
         {
             int i = 1;
+
             await foreach (SpaceTuple tuple in agent.EnumerateAsync())
             {
                 Assert.Equal(tuples[i], tuple);
                 i++;
             }
+
+            Assert.Equal(5, i);
+        });
+
+        _ = Task.Run(async () =>
+        {
+            int i = 1;
+
+            await foreach (SpaceTuple tuple in agent.EnumerateAsync(new(consume, 2)))
+            {
+                Assert.Equal(tuples[i], tuple);
+                i++;
+            }
+
+            Assert.Equal(2, i);
         });
 
         int i = 0;