final def stdin[F[_]]()

in modules/core/src/main/scala/tfr/Resources.scala [30:50]

• 20 lines of code
• 7 McCabe index (conditional complexity)

  final def stdin[F[_]](using sync: Sync[F]): Resource[F, InputStream] =
    Resource.fromAutoCloseable(sync.delay(System.in))

  final def file[F[_]](
      path: String
  )(using sync: Sync[F]): Resource[F, InputStream] =
    Resource
      .fromAutoCloseable(sync.delay {
        URI.create(path) match {
          case gcsUri if gcsUri.getScheme == "gs" =>
            val service = StorageOptions.getDefaultInstance.getService
            val blobPath = gcsUri.getPath.tail match {
              case s if s.endsWith("/") => s.init
              case s                    => s
            }
            val readChannel = service.reader(gcsUri.getHost, blobPath)
            Channels.newInputStream(readChannel)
          case uri =>
            Files.newInputStream(Paths.get(uri.getPath))
        }
      })