Wednesday, July 27, 2016

Awesome Akka Streams

Awesome Akka Streams:
 
val X = Source.actorRef[Int](0, OverflowStrategy.dropNew)
val Y = X.to(Sink.foreach(println))
val Z = Y.run()
Z ! "pretty cool"