Fix scala 2.13 compilation error

grouzen · Dec 10, 2023 · 8391b98 · 8391b98
1 parent faed18f
commit 8391b98
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/...les/core/src/main/scala/me/mnedokushev/zio/apache/parquet/core/hadoop/ParquetReader.scala b/...les/core/src/main/scala/me/mnedokushev/zio/apache/parquet/core/hadoop/ParquetReader.scala
@@ -11,7 +11,7 @@ import zio.stream._
 
 import scala.annotation.nowarn
 
-trait ParquetReader[A <: Product] {
+trait ParquetReader[+A <: Product] {
 
   def read(path: Path): ZStream[Scope, Throwable, A]
 

diff --git a/...les/core/src/main/scala/me/mnedokushev/zio/apache/parquet/core/hadoop/ParquetWriter.scala b/...les/core/src/main/scala/me/mnedokushev/zio/apache/parquet/core/hadoop/ParquetWriter.scala
@@ -12,7 +12,7 @@ import org.apache.parquet.schema.{ MessageType, Type }
 import zio._
 import zio.schema.Schema
 
-trait ParquetWriter[A <: Product] {
+trait ParquetWriter[-A <: Product] {
 
   def write(data: Chunk[A]): Task[Unit]
 

diff --git a/...les/core/src/test/scala/me/mnedokushev/zio/apache/parquet/core/hadoop/ParquetIOSpec.scala b/...les/core/src/test/scala/me/mnedokushev/zio/apache/parquet/core/hadoop/ParquetIOSpec.scala
@@ -37,7 +37,7 @@ object ParquetIOSpec extends ZIOSpecDefault {
           reader <- ZIO.service[ParquetReader[Record]]
           _      <- writer.write(payload)
           _      <- writer.close // force to flush parquet data on disk
-          result <- ZIO.scoped(reader.read(tmpPath).runCollect)
+          result <- ZIO.scoped[Any](reader.read(tmpPath).runCollect)
         } yield assertTrue(result == payload)
       }.provide(
         ParquetWriter.configured[Record](tmpPath),