diff --git a/src/core/Akka.Streams/Util/EnumeratorEnumerable.cs b/src/core/Akka.Streams/Util/EnumeratorEnumerable.cs index 9aab22d59db..3702575f47d 100644 --- a/src/core/Akka.Streams/Util/EnumeratorEnumerable.cs +++ b/src/core/Akka.Streams/Util/EnumeratorEnumerable.cs @@ -28,7 +28,7 @@ public EnumeratorEnumerable(Func> enumeratorFactory) _enumeratorFactory = enumeratorFactory; } - /// + public IEnumerator GetEnumerator() => _enumeratorFactory(); IEnumerator IEnumerable.GetEnumerator() => GetEnumerator(); @@ -57,7 +57,7 @@ public ContinuallyEnumerator(Func> enumeratorFactory) _enumeratorFactory = enumeratorFactory; } - /// + public void Dispose() => _enumeratorFactory = null; /// @@ -76,10 +76,10 @@ public bool MoveNext() return true; } - /// + public void Reset() => _current = _enumeratorFactory(); - /// + public T Current => _current.Current; object IEnumerator.Current => Current; @@ -96,7 +96,7 @@ public ContinuallyEnumerable(Func> enumeratorFactory) _continuallyEnumerator = new ContinuallyEnumerator(enumeratorFactory); } - /// + public IEnumerator GetEnumerator() => _continuallyEnumerator; IEnumerator IEnumerable.GetEnumerator() => GetEnumerator();