jmcardon

package akka.http.scaladsl

import java.io.File

import akka.http.scaladsl.unmarshalling.Unmarshal
import akka.util.ByteString

import scala.concurrent.duration._

import akka.actor.ActorSystem

jmcardon

import akka.http.scaladsl.marshallers.sprayjson.SprayJsonSupport
import akka.http.scaladsl.server.{ HttpApp, Route }
import spray.json.DefaultJsonProtocol

case class SomeFooData(foo: String)

object SomeFooDataSupport extends DefaultJsonProtocol with SprayJsonSupport {
  implicit val PortofolioFormats = jsonFormat1(SomeFooData)
}

jmcardon

sealed trait PitStuff
case class Rise(start: Int, end: Int) extends PitStuff
case class Fall(start: Int, end: Int) extends PitStuff

object kek extends App {
  
  def checkMax(current: Int, rise: Option[Rise], fall: Option[Fall], list: List[Int], maxPit: Int): Int ={
  list match {
    case Nil =>
      if(rise.isDefined && fall.isDefined)

jmcardon

import scala.concurrent.duration._

object Hi extends App {

  case class A[K](k: K)

  /**
   * Settings for producers. See `akka.kafka.producer` section in
   * reference.conf. Note that the [[ProducerSettings companion]] object provides
   * `apply` and `create` functions for convenient construction of the settings, together with

jmcardon

Balaji Sivaraman @balajisivaraman_twitter

Hi all, I need some help understanding a piece of Doobie code from the examples. It is the StreamingCopy one: (https://github.com/tpolecat/doobie/blob/series/0.4.x/yax/example/src/main/scala/example/StreamingCopy.scala). I am using a modified version of the fuseMap2 example from that file. Here’s how I’ve modified it for my requirements:

  def fuseMap[F[_]: Catchable: Monad, A, B](
      source: Process[ConnectionIO, A],
      sink: Vector[A] => ConnectionIO[B],
      delete: ConnectionIO[Unit]
  )(
 sourceXA: Transactor[F],

jmcardon

for fs2 chunk size: 4096

sbt:stream-benchmarks> jmh:run -i 10 -wi 10 -f1 -t1 .*LargeStream*
[info] Running (fork) org.openjdk.jmh.Main -i 10 -wi 10 -f1 -t1 .*LargeStream*
[info] # JMH version: 1.19
[info] # VM version: JDK 1.8.0_144, VM 25.144-b01
[info] # VM invoker: /usr/lib/jvm/java-8-oracle/jre/bin/java
[info] # VM options: <none>
[info] # Warmup: 10 iterations, 1 s each
[info] # Measurement: 10 iterations, 1 s each

jmcardon

package io.github.jmcardon.tseclogin

import tsec.common._
import tsec.mac.core.MAC
import tsec.mac.imports._
import java.util.UUID
import java.time._
import cats.effect.IO

//Using cats-effect 0.5.0 and tsec 0.0.1-M6

jmcardon

public class HttpPipelineFactory implements ChannelPipelineFactory {
  private final ExecutionHandler executionHandler;
  private final ProductDaoImpl   productDao;

  public HttpPipelineFactory(ProductDaoImpl productDao,
      OrderedMemoryAwareThreadPoolExecutor eventExecutor) {
    this.productDao = productDao;
    this.executionHandler = new ExecutionHandler(eventExecutor);
  }

jmcardon

public class HttpPipelineFactory implements ChannelPipelineFactory {
  private final ExecutionHandler executionHandler;
  private final ProductDaoImpl   productDao;

  public HttpPipelineFactory(ProductDaoImpl productDao,
      OrderedMemoryAwareThreadPoolExecutor eventExecutor) {
    this.productDao = productDao;
    this.executionHandler = new ExecutionHandler(eventExecutor);
  }

jmcardon

/** Method in question:
  * https://github.com/circe/circe/blob/master/modules/core/shared/src/main/scala/io/circe/JsonObject.scala#L260
  */
object GucciMane extends App {

  println(classOf[io.circe.JsonObject$].getMethod("fromLinkedHashMap")) //Throws NoSuchMethodException

}