Manifesto.scala

package scalaz.stream.examples

import scala.util.Random
import scalaz.concurrent.Task
import scalaz.stream._

object Manifesto extends App {
  val reactivemanifestowords = "Application requirements have changed dramatically in recent years. Only a few years ago a large application had tens of servers, seconds of response time, hours of offline maintenance and gigabytes of data. Today applications are deployed on everything from mobile devices to cloud-based clusters running thousands of multicore processors. Users expect millisecond or even microsecond response times and 100% uptime. Data needs are expanding into the petabytes.".split(" ").toIndexedSeq

  val randomWord: Process[Task, String] =
    Process.repeatEval(Task.delay(Random.shuffle(reactivemanifestowords).head))

  val aggregateWords: Process1[String, String] =
    process1.chunk(2).map(_.mkString(" "))

  val process = randomWord.pipe(aggregateWords).through(io.stdOutLines)

  process.run.run
}