def resourceReader[F[_]: Sync, A]()

in modules/core/src/main/scala/tfr/TFRecord.scala [109:114]

• 6 lines of code
• 1 McCabe index (conditional complexity)

  def resourceReader[F[_]: Sync, A](
      reader: Kleisli[F, InputStream, Either[Error, A]]
  ): Kleisli[Stream[F, *], Resource[F, InputStream], Either[Error, A]] =
    Kleisli { resource =>
      Stream.resource(resource).flatMap(streamReader(reader).run)
    }