修复bug

xuejmnet · xuejmnet · commit 85dc96cf73f0 · 2022-07-26T13:56:45.000+08:00
diff --git a/src/ShardingCore/Sharding/Enumerators/StreamMergeAsync/OneAtMostElementStreamMergeAsyncEnumerator.cs b/src/ShardingCore/Sharding/Enumerators/StreamMergeAsync/OneAtMostElementStreamMergeAsyncEnumerator.cs
@@ -8,7 +8,7 @@ namespace ShardingCore.Sharding.Enumerators.StreamMergeAsync
 {
     internal class OneAtMostElementStreamMergeAsyncEnumerator<T> : IStreamMergeAsyncEnumerator<T>
     {
-        private int _moveIndex = 0;
+        private int _moveIndex = -1;
         private T _constantElement;
 
         public OneAtMostElementStreamMergeAsyncEnumerator(IStreamMergeAsyncEnumerator<T> streamMergeAsyncEnumerator)
@@ -79,7 +79,7 @@ public bool HasElement()
 
         public void Reset()
         {
-            throw new NotImplementedException();
+            _moveIndex = 0;
         }
 
         object IEnumerator.Current => Current;

Original file line number	Diff line number	Diff line change
`@@ -8,7 +8,7 @@ namespace ShardingCore.Sharding.Enumerators.StreamMergeAsync`
`8`	`8`	`{`
`9`	`9`	`internal class OneAtMostElementStreamMergeAsyncEnumerator<T> : IStreamMergeAsyncEnumerator<T>`
`10`	`10`	`{`
`11`		`- private int _moveIndex = 0;`
	`11`	`+ private int _moveIndex = -1;`
`12`	`12`	`private T _constantElement;`
`13`	`13`
`14`	`14`	`public OneAtMostElementStreamMergeAsyncEnumerator(IStreamMergeAsyncEnumerator<T> streamMergeAsyncEnumerator)`
`@@ -79,7 +79,7 @@ public bool HasElement()`
`79`	`79`
`80`	`80`	`public void Reset()`
`81`	`81`	`{`
`82`		`- throw new NotImplementedException();`
	`82`	`+ _moveIndex = 0;`
`83`	`83`	`}`
`84`	`84`
`85`	`85`	`object IEnumerator.Current => Current;`