Skip to content

Instantly share code, notes, and snippets.

Doing my stuff

Filippo De Luca filosganga

Doing my stuff
View GitHub Profile
filosganga / JsonTagger.scala
Last active Oct 27, 2021
The JSON tagger allows to decode an ADT encoded in JSON avoiding the focus to switch to a different branch
View JsonTagger.scala
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]] =
filosganga / GuavaFutures.scala
Created Sep 16, 2017
How to convert a Guava ListeanbelFuture to Cats Async
View GuavaFutures.scala
import cats.effect.Async
import{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] = {
View time-avro-example.avsc
"type" : "record",
"name" : "TimeExamples",
"namespace": "com.example",
"fields" : [
"name": "aDate",
"type": "int"
"logicalType": "date"
filosganga / Memoize.scala
Last active Mar 5, 2020
Computational memoization
View Memoize.scala
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 / Queue.scala
Created Feb 25, 2020
Several effectful Queue implementation using cats-effect
View Queue.scala
import cats.implicits._
import cats.effect._
import cats.effect.concurrent._
trait Queue[F[_], A] {
def enqueue(a: A): F[Unit]
def dequeue: F[A]
* 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
filosganga / ResourceMapStage.scala
Last active Mar 23, 2017
A map stage that control a resource lifecycle.
View ResourceMapStage.scala
import{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]("")
val out = Outlet[Out]("ResourceMap.out")
filosganga /
Last active Dec 9, 2016
GWT RPC Spring Scaffolding
package org.filippodeluca.gwt.examples.contacts;
public class Contact implements IsSerializable {
private String name;
private String email;
public Contact(String name, String email) {

Keybase proof

I hereby claim:

  • I am filosganga on github.
  • I am filippodeluca ( on keybase.
  • I have a public key ASC15nUa_a2CLHbteLCqNLcJOdILRNSHq5YRpdaV2xplzAo

To claim this, I am signing this object:

filosganga / CycleIterator.scala
Created Oct 27, 2013
An Iterator that cycles trough the given elements
View CycleIterator.scala
class CycleIterator[B <: A, +A](elements: Iterable[B]) extends Iterator[A] {
var iterator: Iterator[B] = Iterator.empty
def hasNext: Boolean = {
if (!iterator.hasNext) {
iterator = elements.iterator