Check Chunk for Streaming Responses

gistfile1.txt

import fs2._

object CheckChunk {
  def checkChunk[F[_]: Sync, A](s: Stream[F, A]): F[Option[Stream[F, A]]] = {
    s.pull
      .uncons
      .flatMap {
        case None => Pull.output1(None)
        case Some((c, s)) => Pull.extendScopeTo(Stream.chunk(c) ++ s).flatMap(s => Pull.output1(Some(s)))
      }
      .stream
      .compile
      .lastOrError
  }
}