Skip to content

Instantly share code, notes, and snippets.

@Bekbolatov

Bekbolatov/AkkaStreams.scala

Created July 27, 2016 06:20
Show Gist options
  • Save Bekbolatov/c1c83a5060b2c0e973c82115539689f9 to your computer and use it in GitHub Desktop.
Save Bekbolatov/c1c83a5060b2c0e973c82115539689f9 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
AkkaStreams.scala
val X = Source.actorRef[Int](0, OverflowStrategy.dropNew)
val Y = X.to(Sink.foreach(println))
val Z = Y.run()
Z ! "pretty cool"
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment