enumResultSet

enumResultSet.scala

def enumResultSet[E,A](rs: ResultSet, iter: IterV[E, A], get: ResultSet => IO[E]): IO[IterV[E, A]] = {
    def loop(i: IterV[E, A]): IO[IterV[E, A]] =
      i.fold(done = (_, _) => i.pure[IO],
             cont = k => next(rs) >>= (hasMore =>
                         if (!hasMore) i.pure[IO]
                         else get(rs) >>= (t => loop(k(El(t))))))
    loop(iter)
}