mkows · August 4, 2016 16:25 · mkows · Aug 4, 2016
diff --git a/fs2-process-seq.scala b/fs2-process-seq.scala
 object Fs2GuideApp extends App {

  import fs2.Stream
  import fs2.Task

  def printTask(i: Int): Task[Boolean] = {
    Task.delay {
      println(s"started: $i")
      Thread.sleep(200)
      println(s"ended__: $i")
      true
    }
  }

  val input  = (1 to 20).toList

  val x = Stream.emits(input).map { i => // compare with -> val x = Stream.emits(input).unchunk.map { i =>
    printTask(i).map {
      case res if i < 3 => !res
      case res if i >= 3 => res
    }
  }.flatMap(Stream.eval)

  val res = x.runLog.unsafeRun()

  println(s"res = $res")
 }
	object Fs2GuideApp extends App {

	import fs2.Stream
	import fs2.Task

	def printTask(i: Int): Task[Boolean] = {
	Task.delay {
	println(s"started: $i")
	Thread.sleep(200)
	println(s"ended__: $i")
	true
	}
	}

	val input = (1 to 20).toList

	val x = Stream.emits(input).map { i => // compare with -> val x = Stream.emits(input).unchunk.map { i =>
	printTask(i).map {
	case res if i < 3 => !res
	case res if i >= 3 => res
	}
	}.flatMap(Stream.eval)

	val res = x.runLog.unsafeRun()

	println(s"res = $res")
	}