Skip to content

Instantly share code, notes, and snippets.

View pchlupacek's full-sized avatar

Pavel Chlupacek pchlupacek

View GitHub Profile
@pchlupacek
pchlupacek / par_join_test.scala
Last active January 20, 2019 07:52
fs2 par join - comparison
/* related to case https://github.com/functional-streams-for-scala/fs2/issues/1397 **/
package fs2.concurrent
import java.util.concurrent.Executors
import cats.Traverse
import cats.implicits._
import cats.effect.{ExitCode, IO, IOApp}
package fs2.benchmark
import java.util.concurrent.TimeUnit
import cats.implicits._
import cats.effect.{Concurrent, ContextShift, IO}
import org.openjdk.jmh.annotations.{Benchmark, BenchmarkMode, Mode, OutputTimeUnit, Scope, State}
import fs2._
import fs2.concurrent.{SignallingRef, Topic}
{
"ignition": {
"config": {},
"security": {
"tls": {}
},
"timeouts": {},
"version": "2.2.0"
},
"networkd": {},