Tutorial by Examples: akka

Add akka-actor dependency (SBT example) libraryDependencies += "com.typesafe.akka" % "akka-actor_2.11" % "2.4.8" Create actor classes: Actor for string output: class OutputActor extends Actor { override def receive: Receive = { case message => p...

Add this dependency to your project POM: <dependency> <groupId>com.typesafe.akka</groupId> <artifactId>akka-actor_2.11</artifactId> <version>2.4.4</version> </dependency> Create an Actor public class HelloWorldActor ext...

Akka Streams allows you to easily create a stream leveraging the power of the Akka framework without explicitly defining actor behaviors and messages. Every stream will have at least one Source (origin of the data) and at least one Sink (destination of the data). import akka.actor.ActorSystem impo...

You can dynamically fork a flow in multiple subflows using groupBy. The continuing stages are applied to each subflow until you merge them back using mergeSubstreams. val sumByKey: Flow[(String, Int), Int, NotUsed] = Flow[(String, Int)]. groupBy(Int.maxValue, _._1). //forks the flow ...

The following app will start an HTTP server listening on port 8080 that returns Hello world on GET /hello/world import akka.actor.ActorSystem import akka.http.scaladsl.Http import akka.http.scaladsl.server.Directives._ import akka.http.scaladsl.server._ import akka.stream.ActorMaterializer i...