Skip to content

Instantly share code, notes, and snippets.

View leftofnull's full-sized avatar

Alexander Kahoun leftofnull

View GitHub Profile
package com.leftofnull.streams
import akka.stream._
import akka.stream.scaladsl._
import akka.stream.stage.{GraphStage, GraphStageLogic, InHandler, OutHandler}
import cats.data.Xor
import cats.data.Xor._
import com.typesafe.scalalogging.LazyLogging
import scala.concurrent.blocking
import scala.language.{implicitConversions, postfixOps}