// Licensed to the .NET Foundation under one or more agreements. // The .NET Foundation licenses this file to you under the Apache 2.0 License. // See the LICENSE file in the project root for more information. using System.Collections.Generic; using System.Linq; using System.Threading; using BenchmarkDotNet.Attributes; namespace Benchmarks.System.Interactive { [MemoryDiagnoser] public class BufferCountBenchmark { [Params(1, 10, 100, 1000, 10000, 100000, 1000000)] public int N; private IList? _store; [Benchmark] public void Exact() { Enumerable.Range(1, N) .Buffer(1) .Subscribe(v => Volatile.Write(ref _store, v)); } [Benchmark] public void Skip() { Enumerable.Range(1, N) .Buffer(1, 2) .Subscribe(v => Volatile.Write(ref _store, v)); } [Benchmark] public void Overlap() { Enumerable.Range(1, N) .Buffer(2, 1) .Subscribe(v => Volatile.Write(ref _store, v)); } } }