fingo / spata Goto Github PK

.render
.through(fs2.text.char2string)
.through(fs2.text.utf8.encode)

  def render: Pipe[F, Record, Char] = (in: Stream[F, Record]) =>
    def loop(in: Stream[F, Record], header: Header): Pull[F, Either[HeaderError, String], Unit] =
      in.pull.uncons.flatMap:
        case Some((rc, t)) => Pull.output(rc.map(renderRow(_, header))) >> loop(t, header)
        case None => Pull.done
    val pull = in.pull.uncons1.flatMap:
      case Some((r, t)) =>
        val headerRow = if config.hasHeader then Pull.output1(renderHeader(r.header)) else Pull.pure(())
        val firstRow = Pull.output1(renderRow(r, r.header))
        headerRow >> firstRow >> loop(t, r.header)
      case None => Pull.done
    pull.stream.through(toChars)

  private def toChars: Pipe[F, EHE[String], Char] = (in: Stream[F, EHE[String]]) =>
    in.rethrow
      .intersperse(srd)
      .map(s => Chunk.array[Char](s.toCharArray))
      .flatMap(Stream.chunk)

val stream: Stream[IO, Record] = ???
val renderer: CSVRenderer[IO] =
  CSVRenderer.config.mapHeader(Map("tempMax" -> "max temparature", "tempMin" -> "min temparature")).renderer[IO]
val frosty: Stream[IO, Char] = stream.filter(_.get[Double]("minTemp").exists(_ < 0)).through(renderer.render)