gistfile1.scala

import scalaz.stream._
import scalaz.concurrent.Task

object ChunkTest {

  def main(args: Array[String]): Unit = {

    def expensive[T](x:T): T = {
      println(s"EXPENSIVE! $x")
      x
    }

    val range: Process[Task,Int] = Process.range(0,4)
    val chunked: Process[Task,Vector[Int]] =
      range.chunk(2)

    println("range:")
    println(range.runLog.run)
    println("\nrange.map(expensive):")
    println(range.map(expensive).runLog.run)
    println("\nrange.zipWithIndex.map{(case (x,i) => (expensive(x),i)}:")
    println(range.zipWithIndex.map { case (x,i) => (expensive(x),i) }.runLog.run)
    println("\nrange.map(expensive).zipWithIndex:")
    println(range.map(expensive).zipWithIndex.runLog.run)

    println("\nchunked:")
    println(chunked.runLog.run)
    println("\nchunked.map(expensive):")
    println(chunked.map(expensive).runLog.run)
    println("\nchunked.map(expensive).zipWithIndex:")
    println(chunked.map(expensive).zipWithIndex.runLog.run)
    println("\nchunked.zipWithIndex.map{(case (x,i) => (expensive(x),i)}:")
    println(chunked.zipWithIndex.map { case (x,i) => (expensive(x),i) }.runLog.run)

    }

}