Skip to content

Instantly share code, notes, and snippets.

View lJoublanc's full-sized avatar

Luciano lJoublanc

6 followers · 16 following
  • Digital Asset
  • Zürich
View GitHub Profile
@lJoublanc
lJoublanc / race.scala
Created August 9, 2017 15:29
Example of race condition fs2 branch 0.10.0: Signal completes before we can get any values out.
import fs2._
import cats.effect._
import fs2.async.mutable.Signal
import scala.concurrent.ExecutionContext.Implicits.global
implicit val ioInstance = Effect[IO]
val input = Stream.range(1,20).covary[IO] // <-- try changing this to range(1,2), result is empty!
val output : Stream[IO,Signal[IO,Option[Int]]] =
Stream eval async.signalOf[IO,Option[Int]](Some(0)) flatMap { sig =>
@lJoublanc
lJoublanc / Example.scala
Created January 11, 2017 08:54
Example of how to use Slick's MappedJdbcType in practice
// This does the conversion from enum to char and vice-versa.
abstract class JDBCCharEnumeration extends Enumeration {
import slick.jdbc.HsqldbProfile.api._ //from what I recall changing this to JDBCProfile does *not* work. Must use specific driver.
import slick.jdbc.HsqldbProfile.MappedJdbcType
implicit def enumMapper = MappedJdbcType.base[Value,Char](_.id.toChar, this(_))
}
// The enumeration
object OrderExpiry extends JDBCCharEnumeration {
@lJoublanc
lJoublanc / testpickle.ipynb
Created December 29, 2014 14:50
Serializing pandas df to mongodb using existing msgpack packers
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.