Skip to content

Instantly share code, notes, and snippets.

View gopalakrishnan-subramani's full-sized avatar

Gopalakrishnan Subramani gopalakrishnan-subramani

View GitHub Profile
@adamw
adamw / windowing.scala
Created August 5, 2016 13:30
Windowing data in Akka
package com.softwaremill.akka
import java.time._
import akka.actor.ActorSystem
import akka.stream.ActorMaterializer
import akka.stream.scaladsl.Source
import scala.collection.mutable
import scala.concurrent.Await