Artem Nikiforov

``` Benchmark 3.2.9- 3.2.9+ 3.3.0- 3.3.0+ 3.2.9- 3.2.9+ 3.3.0- 3.3.0+ DriverBenchmark.return100Records 7.010 7.986 7.792 10.010 7.325 8.001 7.662 10.424 DriverBenchmark.return100Records:·gc.alloc.rate 246.768 217.543 220.893 178.274 249.123 217.396 237.331 182.919 DriverBenchmark.return100Records:·gc.alloc.rate.norm 3068430.610...

I'll leave this comment here, it may be relevant(I see `as` == `map` in both examples). https://github.com/typelevel/fs2/issues/2785#issuecomment-1007825447

I haven't measured perfomance of akka-streams yet, but I've repeated almost everything you've written about fs2 using jmh. This is the benchmark ``` @State(Scope.Thread) class BroadcastBenchmark { val executor =...

> Am I reading the benchmark output lines for `streamSize` ∈ {1000, 100000} correctly that even though we’re processing 100 times more elements in the `streamSize` = 100000 run, the...

@balthz, I've changed two things in the Benchmark: - Stream is formed in Setup method - Execution is blocked on the blocker. The only action, that happends on the benchmark's...

> ``` > val executor = Executors.newSingleThreadExecutor > ``` > > mmm Actually that was intentional! :))) And I want to discuss this a bit, if you don't mind. I'm...

> @nikiforo I have run today the benchmarks, using the current `main` branch (to be 3.0.0 release). It seems that the problem has been solved in this release.``` @diesalbla, I...

@diesalbla @SystemFw, ``` package fs2 package benchmark import cats.effect.IO import cats.effect.unsafe.implicits.global import org.openjdk.jmh.annotations.{Benchmark, Param, Scope, State} @State(Scope.Thread) class BroadcastBenchmark { val drainPipe: Pipe[IO, Int, INothing] = _.drain @Param(Array("10", "1000", "100000"))...

`parEvalMap` & `parEvalMapUnordered` were reimplemented with [5x](https://github.com/typelevel/fs2/pull/2673#issuecomment-970270973) & [4x](https://github.com/typelevel/fs2/pull/2626#issue-1002992058) performance boosts respectively. I'm not sure whether we should port them to 2.x branch, because `parEvalMap*` methods currently contain cancelation and...

I liked a lot solving this one Q: merge part of mergeSort. Combine two ordered ascending Int streams to a single ordered ascending Int stream. A: ``` import fs2.Chunk import...