optimize sequences and they api

Benchmarks/Falko.Talkie.Benchmarks.Sequences/Benchmarks/FrozenSequenceForEachAsyncBenchmark.cs

@@ -0,0 +1,38 @@
+using BenchmarkDotNet.Attributes;
+using BenchmarkDotNet.Engines;
+using Talkie.Models;
+using Talkie.Sequences;
+
+namespace Talkie.Benchmarks.Benchmarks;
+
+[SimpleJob(RunStrategy.Throughput)]
+public class FrozenSequenceForEachAsyncBenchmark
+{
+    private const int IterationsCount = 10;
+
+    private readonly FrozenSequence<Reference> _frozenSequence = new(Enumerable.Repeat(Reference.Shared, IterationsCount));
+
+    [Benchmark]
+    public async Task FrozenSequenceEnumerableWrapperForEach()
+    {
+        foreach (var reference in _frozenSequence.AsEnumerable()) _ = reference;
+
+        await Task.CompletedTask;
+    }
+
+    [Benchmark]
+    public async Task FrozenSequenceEnumerableCastForEach()
+    {
+        foreach (var reference in (IEnumerable<Reference>)_frozenSequence) _ = reference;
+
+        await Task.CompletedTask;
+    }
+
+    [Benchmark]
+    public async Task FrozenSequenceExtensionsForEach()
+    {
+        _frozenSequence.ForEach(reference => _ = reference);
+
+        await Task.CompletedTask;
+    }
+}

Benchmarks/Falko.Talkie.Benchmarks.Sequences/Benchmarks/FrozenSequenceForEachBenchmark.cs

@@ -0,0 +1,50 @@
+using BenchmarkDotNet.Attributes;
+using BenchmarkDotNet.Engines;
+using Talkie.Models;
+using Talkie.Sequences;
+
+namespace Talkie.Benchmarks.Benchmarks;
+
+[SimpleJob(RunStrategy.Throughput)]
+public class FrozenSequenceForEachBenchmark
+{
+    private const int IterationsCount = 10;
+
+    private readonly FrozenSequence<Reference> _frozenSequence = new(Enumerable.Repeat(Reference.Shared, IterationsCount));
+
+    [Benchmark]
+    public void FrozenSequenceStructForEach()
+    {
+        foreach (var reference in _frozenSequence) _ = reference;
+    }
+
+    [Benchmark]
+    public void FrozenSequenceEnumerableWrapperForEach()
+    {
+        foreach (var reference in _frozenSequence.AsEnumerable()) _ = reference;
+    }
+
+    [Benchmark]
+    public void FrozenSequenceEnumerableCastForEach()
+    {
+        foreach (var reference in (IEnumerable<Reference>)_frozenSequence) _ = reference;
+    }
+
+    [Benchmark]
+    public void FrozenSequenceMemoryForEach()
+    {
+        foreach (var reference in _frozenSequence.AsMemory().Span) _ = reference;
+    }
+
+    [Benchmark]
+    public void FrozenSequenceSpanForEach()
+    {
+        foreach (var reference in _frozenSequence.AsSpan()) _ = reference;
+    }
+
+    [Benchmark]
+    public void FrozenSequenceExtensionsForEach()
+    {
+        _frozenSequence.ForEach(reference => _ = reference);
+    }
+}

Benchmarks/Falko.Talkie.Benchmarks.Sequences/Benchmarks/AddBenchmark.cs → Benchmarks/Falko.Talkie.Benchmarks.Sequences/Benchmarks/SequencesVsOtherAddBenchmark.cs

@@ -7,7 +7,7 @@ namespace Talkie.Benchmarks.Benchmarks;
 
 [MemoryDiagnoser]
 [SimpleJob(RunStrategy.Throughput)]
-public class AddBenchmark
+public class SequencesVsOtherAddBenchmark
 {
     [Params(0, 1, 10, 100, 1000, 10000)]
     public int Capacity { get; set; }

Benchmarks/Falko.Talkie.Benchmarks.Sequences/Benchmarks/FirstAndLastBenchmark.cs → Benchmarks/Falko.Talkie.Benchmarks.Sequences/Benchmarks/SequencesVsOtherFirstAndLastBenchmark.cs

@@ -7,7 +7,7 @@ namespace Talkie.Benchmarks.Benchmarks;
 
 [MemoryDiagnoser]
 [SimpleJob(RunStrategy.Throughput)]
-public class FirstAndLastBenchmark
+public class SequencesVsOtherFirstAndLastBenchmark
 {
     private const int Capacity = 10;
 

Benchmarks/Falko.Talkie.Benchmarks.Sequences/Benchmarks/ForeachBenchmark.cs → Benchmarks/Falko.Talkie.Benchmarks.Sequences/Benchmarks/SequencesVsOtherForEachBenchmark.cs

@@ -7,7 +7,7 @@ namespace Talkie.Benchmarks.Benchmarks;
 
 [MemoryDiagnoser]
 [SimpleJob(RunStrategy.Throughput)]
-public class ForeachBenchmark
+public class SequencesVsOtherForEachBenchmark
 {
     private FrozenSequence<Reference>? _frozenSequence;
 

Benchmarks/Falko.Talkie.Benchmarks.Sequences/Benchmarks/RemoveBenchmark.cs → Benchmarks/Falko.Talkie.Benchmarks.Sequences/Benchmarks/SequencesVsOtherRemoveBenchmark.cs

@@ -7,7 +7,7 @@ namespace Talkie.Benchmarks.Benchmarks;
 
 [MemoryDiagnoser]
 [SimpleJob(RunStrategy.Throughput)]
-public class RemoveBenchmark
+public class SequencesVsOtherRemoveBenchmark
 {
     private IEnumerable<RemovableSequence<Reference>.Remover>? _removableSequenceRemovers;
 

Benchmarks/Falko.Talkie.Benchmarks.Sequences/Program.cs

@@ -1,7 +1,9 @@
 using BenchmarkDotNet.Running;
 using Talkie.Benchmarks.Benchmarks;
 
-BenchmarkRunner.Run<AddBenchmark>();
-BenchmarkRunner.Run<FirstAndLastBenchmark>();
-BenchmarkRunner.Run<RemoveBenchmark>();
-BenchmarkRunner.Run<ForeachBenchmark>();
+BenchmarkRunner.Run<FrozenSequenceForEachAsyncBenchmark>();
+BenchmarkRunner.Run<FrozenSequenceForEachBenchmark>();
+BenchmarkRunner.Run<SequencesVsOtherFirstAndLastBenchmark>();
+BenchmarkRunner.Run<SequencesVsOtherAddBenchmark>();
+BenchmarkRunner.Run<SequencesVsOtherRemoveBenchmark>();
+BenchmarkRunner.Run<SequencesVsOtherForEachBenchmark>();

Sources/Falko.Talkie.Core/Sequences/FrozenSequence.Enumerable.cs

@@ -0,0 +1,28 @@
+using System.Collections;
+using System.Runtime.CompilerServices;
+using System.Runtime.InteropServices;
+
+namespace Talkie.Sequences;
+
+public partial class FrozenSequence<T>
+{
+    public readonly struct Enumerable : IEnumerable<T>
+    {
+        private readonly T[] _values;
+
+        private readonly int _valuesCount;
+
+        [MethodImpl(MethodImplOptions.AggressiveInlining)]
+        internal Enumerable(T[] values, int valuesCount)
+        {
+            _values = values;
+            _valuesCount = valuesCount;
+        }
+
+        [MethodImpl(MethodImplOptions.AggressiveInlining)]
+        public IEnumerator<T> GetEnumerator() => new Enumerator(_values, _valuesCount);
+
+        [MethodImpl(MethodImplOptions.AggressiveInlining)]
+        IEnumerator IEnumerable.GetEnumerator() => new Enumerator(_values, _valuesCount);
+    }
+}

Sources/Falko.Talkie.Core/Sequences/FrozenSequence.HeapEnumerator.cs → Sources/Falko.Talkie.Core/Sequences/FrozenSequence.Enumerator.cs

@@ -6,7 +6,7 @@ namespace Talkie.Sequences;
 
 public partial class FrozenSequence<T>
 {
-    public struct HeapEnumerator : IEnumerator<T>
+    public struct Enumerator : IEnumerator<T>
     {
         private readonly T[] _values;
 
@@ -17,7 +17,7 @@ public struct HeapEnumerator : IEnumerator<T>
         private T _currentValue = default!;
 
         [MethodImpl(MethodImplOptions.AggressiveInlining)]
-        internal HeapEnumerator(T[] values, int valuesCount)
+        internal Enumerator(T[] values, int valuesCount)
         {
             _values = values;
             _valuesCount = valuesCount;

Sources/Falko.Talkie.Core/Sequences/FrozenSequence.Linq.cs

@@ -66,4 +66,18 @@ public bool Contains(T value, IEqualityComparer<T> comparer)
 
         return false;
     }
+
+    public ReadOnlySpan<T> AsSpan() => _items.AsSpan();
+
+    public ReadOnlyMemory<T> AsMemory() => _items.AsMemory();
+
+    public Enumerable AsEnumerable() => new(_items, _itemsCount);
+
+    public T[] ToArray() => _items.ToArray();
+
+    public void CopyTo(T[] array, int arrayIndex) => _items.CopyTo(array, arrayIndex);
+
+    public void CopyTo(Span<T> span) => _items.CopyTo(span);
+
+    public void CopyTo(Memory<T> memory) => _items.CopyTo(memory);
 }

Sources/Falko.Talkie.Core/Sequences/FrozenSequence.StackEnumerator.cs → Sources/Falko.Talkie.Core/Sequences/FrozenSequence.StructEnumerator.cs

@@ -6,7 +6,7 @@ namespace Talkie.Sequences;
 
 public partial class FrozenSequence<T>
 {
-    public ref struct StackEnumerator : IEnumerator<T>
+    public ref struct StructEnumerator : IEnumerator<T>
     {
         private readonly ref T _valuesReference;
 
@@ -17,7 +17,7 @@ public partial class FrozenSequence<T>
         private T _currentValue = default!;
 
         [MethodImpl(MethodImplOptions.AggressiveInlining)]
-        internal StackEnumerator(T[] values, int valuesCount)
+        internal StructEnumerator(T[] values, int valuesCount)
         {
             _valuesReference = ref MemoryMarshal.GetArrayDataReference(values);
             _valuesCount = valuesCount;

Sources/Falko.Talkie.Core/Sequences/FrozenSequence.cs

@@ -19,11 +19,11 @@ public FrozenSequence(IEnumerable<T> values)
 
     public int Count => _itemsCount;
 
-    public StackEnumerator GetEnumerator() => new(_items, _itemsCount);
+    public StructEnumerator GetEnumerator() => new(_items, _itemsCount);
 
-    IEnumerator<T> IEnumerable<T>.GetEnumerator() => new HeapEnumerator(_items, _itemsCount);
+    IEnumerator<T> IEnumerable<T>.GetEnumerator() => new Enumerator(_items, _itemsCount);
 
-    IEnumerator IEnumerable.GetEnumerator() => new HeapEnumerator(_items, _itemsCount);
+    IEnumerator IEnumerable.GetEnumerator() => new Enumerator(_items, _itemsCount);
 
     public IParallelEnumerator<T> GetParallelEnumerator() => new ParallelEnumerator(_items, _itemsCount);
 

Sources/Falko.Talkie.Core/Sequences/SequenceExtensions.ForEach.cs

@@ -54,9 +54,6 @@ public static void ForEach<T>(this FrozenSequence<T> sequence, Action<T> action)
 
         if (sequence.Count is 0) return;
 
-        foreach (var value in sequence)
-        {
-            action(value);
-        }
+        foreach (var value in sequence) action(value);
     }
 }