filosganga

import static com.google.common.base.Preconditions.checkNotNull;
import static com.google.common.collect.Iterables.filter;
import static com.google.common.collect.Iterators.cycle;
import static java.util.Arrays.asList;

import java.util.Iterator;

import com.google.common.base.Function;
import com.google.common.base.Predicate;
import com.google.common.collect.FluentIterable;

filosganga

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

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

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._
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 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

/**
 * Licensed to the Apache Software Foundation (ASF) under one or more 
 * contributor license agreements.  See the NOTICE file distributed with 
 * this work for additional information regarding copyright ownership.  
 * The ASF licenses this file to you under the Apache License, Version 2.0 
 * (the "License"); you may not use this file except in compliance with 
 * the License.  You may obtain a copy of the License at 
 * 
 *   http://www.apache.org/licenses/LICENSE-2.0
 *   

filosganga

import akka.stream.ActorAttributes.SupervisionStrategy
import akka.stream._
import akka.stream.stage.{GraphStage, GraphStageLogic, InHandler, OutHandler}

import scala.util.control.NonFatal

class ResourceMapStage[In, Out, R](opener: () => R, closer: R => Unit, f: R => In ⇒ Out) extends GraphStage[FlowShape[In, Out]] {

  val in = Inlet[In]("ResourceMap.in")
  val out = Outlet[Out]("ResourceMap.out")

filosganga

package org.filippodeluca.gwt.examples.contacts;

import com.google.gwt.user.client.rpc.IsSerializable;

public class Contact implements IsSerializable {

  private String name;
  private String email;

  public Contact(String name, String email) {

filosganga

Keybase proof

I hereby claim:

• I am filosganga on github.
• I am filippodeluca (https://keybase.io/filippodeluca) on keybase.
• I have a public key ASC15nUa_a2CLHbteLCqNLcJOdILRNSHq5YRpdaV2xplzAo

To claim this, I am signing this object: