danicheg

package munit

import cats.effect.{IO, Resource}

// ce3/js/src/main/scala/munit/ResourceSuiteLocalFixturePlatform
private[munit] trait ResourceSuiteLocalFixturePlatform { self: CatsEffectSuite =>
  def createResourceSuiteLocalFixturePlatform[T](
      name: String,
      resource: Resource[IO, T]
  ): Fixture[T] =

danicheg

import cats.effect.Async
import org.apache.kafka.clients.producer.{
  ProducerRecord,
  RecordMetadata,
  KafkaProducer => ApacheKafkaProducer
}
import org.apache.kafka.clients.producer.ProducerConfig
import org.apache.kafka.common.serialization.Serializer
import fs2._

danicheg

package data

import monocle.Lens

trait HasLens[A, B] {
  def lens: Lens[A, B]
}

object HasLens extends HasLensSyntax0

danicheg

Running (fork) scala.future.BenchRunner -p threads=1 -p recursion=8192 -i 30 -wi 15 -f1 -t1 Benchmark
# JMH version: 1.20
# VM version: JDK 1.8.0_151, VM 25.151-b12
# VM invoker: /usr/lib/jvm/java-8-openjdk-amd64/jre/bin/java
# VM options: -Xmx512M -Xms512M -ea -server -XX:+UseCompressedOops -XX:+AlwaysPreTouch -XX:+UseCondCardMark
# Warmup: 15 iterations, 1 s each
# Measurement: 30 iterations, 1 s each
# Timeout: 10 min per iteration
# Threads: 1 thread, will synchronize iterations
# Benchmark mode: Throughput, ops/time

danicheg

Benchmark	(id)	(testUnitsName)	Mode	Cnt	Score	Error	Units
MVarVsTrieMap.getById	foo	MVar	thrpt	10	3.936	± 1.042	ops/ms
MVarVsTrieMap.getById	foo	TrieMap	thrpt	10	1854.225	± 12.373	ops/ms
MVarVsTrieMap.getById	bar	MVar	thrpt	10	3.769	± 0.923	ops/ms
MVarVsTrieMap.getById	bar	TrieMap	thrpt	10	1826.843	± 9.966	ops/ms