diff --git a/stream_bench_test.go b/stream_bench_test.go index 9bda81f..db1602f 100644 --- a/stream_bench_test.go +++ b/stream_bench_test.go @@ -118,7 +118,7 @@ func Benchmark_Distribute(b *testing.B) { } } -func Benchmark_Stream(b *testing.B) { +func Benchmark_Scaler(b *testing.B) { ctx, cancel := context.WithCancel(context.Background()) defer cancel()