fizzbuzz4.scala

import akka.actor.ActorSystem
import akka.stream._
import akka.stream.scaladsl._

import scala.concurrent.duration._
import scala.concurrent.ExecutionContext.Implicits.global

def reactiveFizzbuzz( n: Int )( rules: Int => String ): Source[( Int, String ), _] = {
  Source(
    1 to n
  ).map(x => ( x, rules( x ) ) )
}

implicit val system: ActorSystem = ActorSystem()

reactiveFizzbuzz( N )( basicFizzbuzzRules )
  .throttle( 10, 1.seconds )
  .runForeach( println )
  .andThen(_ => system.terminate )