circe-fs2 example

gistfile1.txt

import cats.effect._
import scala.concurrent.ExecutionContext
import java.nio.file.Paths
import io.circe.generic.auto._
import io.circe.fs2._

implicit val ec: ExecutionContext = ExecutionContext.global
implicit val ioContextShift: ContextShift[IO] = IO.contextShift(ec)

case class Repo(repo: String, stars: Int)

val input = """[
  { "repo": "circe-fs2", "stars": 14 },
  { "repo": "circe-config", "stars": 5 }
]"""


fs2.Stream(input).covary[IO]
  .flatMap{b => fs2.Stream.emits(b.getBytes)}
  .through(byteArrayParser)
  .through(decoder[IO, Repo])