Unzip with Cats Effect

Unzip.scala

import java.io.IOException
import java.nio.file.{Files, Path, StandardOpenOption}
import java.util.zip.{ZipEntry, ZipInputStream}

import cats.effect.{IO, Resource}

object Unzip {

  @throws[IOException]
  def unzip(src: Path, dir: Path) {

    def writeZipEntry(zipInputStream: ZipInputStream, zipEntry: ZipEntry) : IO[Unit] = {
      IO {
        val destFile = dir.resolve(zipEntry.getName)
        Files.createDirectories(destFile.getParent) // ensure dir path exists
        destFile
      }
      .flatMap { destFile =>
        Resource.make(IO { Files.newOutputStream(destFile, StandardOpenOption.CREATE_NEW) })(fos => IO {fos.close()})
          .use { fos =>
            IO {
              val buffer = new Array[Byte](1024)
              Stream.continually(zipInputStream.read(buffer)).takeWhile(_ != -1).foreach(fos.write(buffer, 0, _))
            }
          }
      }
    }

   val x : IO[Stream[IO[Unit]]] =
     Resource
      .make(IO { Files.newInputStream(src)} )(fis => IO { fis.close() })
      .use { fis =>
        Resource.make(IO { new ZipInputStream(fis) })(zis => IO { zis.close() })
          .use { zis =>
            Resource.liftF(IO { Stream.continually(zis.getNextEntry).takeWhile(_ != null) })
              .use { zipEntryStream =>
                IO {
                  zipEntryStream
                    .filter(!_.isDirectory)
                    .map(writeZipEntry(zis, _))
                }
              }
          }
      }

    import cats.implicits._
    x.flatMap(_.sequence_)
  }
}