Running the Akka Streams examples

AkkaStreams.scala

package com.dvidr

import scala.concurrent.ExecutionContext.Implicits.global
import akka.actor.ActorSystem
import akka.stream.ActorMaterializer
import akka.stream.scaladsl.{Sink, Source}
import scala.concurrent.Future
import scala.util.{Success, Failure}


class AkkaStreams

object AkkaStreams {
  def main(args: Array[String]) {
    implicit val actorSystem = ActorSystem("SimpleStreams")
    implicit val materializer = ActorMaterializer()

    val source = Source(1 to 10)
    val sink = Sink.fold[Int, Int](0)(_ + _)

    val sum: Future[Int] = source.runWith(sink)

    sum.onComplete{
      case Success(n) => println(n)
      case Failure(n) => println("Akka Actor failure.")
    }
  }

}