filosganga

{
  "type" : "record",
  "name" : "TimeExamples",
  "namespace": "com.example",
  "fields" : [
    {
      "name": "aDate",
      "type": "int"
      "logicalType": "date"
    },

filosganga

import cats.effect.Async
import com.google.common.util.concurrent.{FutureCallback, Futures, ListenableFuture}

import scala.concurrent.ExecutionContext

object GuavaFutures {

  implicit class RichListenableFuture[T](lf: ListenableFuture[T]) {

    def toAsync[F[_]: Async](implicit ec: ExecutionContext): F[T] = {

filosganga

import cats.data._
import cats.implicits._
import cats.effect._
import cats.effect.concurrent._

trait Queue[F[_], A] {

  def enqueue(a: A): F[Unit]

  def dequeue: F[A]

filosganga

import cats._
import cats.implicits._
import cats.effect._
import cats.effect.concurrent._
import cats.effect.implicits._

trait Memoize[F[_], Key, A] {
  def get(id: Key): F[A]
}

filosganga

import io.circe._
import io.circe.generic.semiauto._
import cats.syntax.all._
  
object JsonTagger {

  private implicit class Tagger[A](d: Decoder[A]) {

    def tag(accessor: String): Decoder[Decoder[A]] =
      Decoder