Skip to content

Instantly share code, notes, and snippets.

package com.ssn
import cats.effect.{Blocker, ExitCode, IO, IOApp}
import cats.implicits._
import doobie.implicits._
import doobie.hikari.HikariTransactor
import doobie.util.ExecutionContexts
import doobie.util.transactor.Transactor
import scala.concurrent.duration._
@msosnicki
msosnicki / Utf8Bug.scala
Created September 25, 2019 16:43
utf8Decode bug
package zio.stream
import zio._
object Utf8Bug extends App {
val char = "\u00BB"
val string = List.fill(10)(char).mkString
val bytes = string.getBytes("UTF-8")
@msosnicki
msosnicki / Example.scala
Last active August 9, 2017 09:36
Monix reactive groupings
package com.rxcorp.cesespoke.filewatcher.obs
import monix.reactive.{Consumer, Observable, Observer}
import monix.eval.Task._
import monix.execution.Ack
import monix.execution.Ack._
import monix.execution.Scheduler.Implicits.global
import scala.concurrent.{Await, Future}
import scala.concurrent.duration._