Skip to content

Commit 8e855f0

Browse files
author
cfernandescaesars
committed
Remove effect covariance as it was affecting 2.12.x
1 parent 22d5e65 commit 8e855f0

File tree

3 files changed

+14
-10
lines changed

3 files changed

+14
-10
lines changed

build.sbt

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -41,8 +41,8 @@ inThisBuild {
4141

4242
ThisBuild / scalacOptions ++= {
4343
CrossVersion.partialVersion(scalaVersion.value) match {
44-
case Some((2, 12 | 13)) =>
45-
Seq(
44+
case Some((2, minor @ (12 | 13))) =>
45+
val base = Seq(
4646
"-deprecation",
4747
"-encoding",
4848
"UTF-8",
@@ -57,6 +57,8 @@ ThisBuild / scalacOptions ++= {
5757
"-Ywarn-unused",
5858
"-Xsource:3"
5959
)
60+
if (minor == 12) "-Ypartial-unification" +: base
61+
else base
6062

6163
case Some((3, _)) =>
6264
Seq.empty

src/main/scala/io/kaizensolutions/jsonschema/JsonSchemaDeserializer.scala

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -17,21 +17,23 @@ import scala.reflect.ClassTag
1717

1818
// See AbstractKafkaJsonSchemaDeserializer
1919
object JsonSchemaDeserializer {
20-
def forValue[F[+_]: Sync, A: Decoder](
20+
def forValue[F[_]: Sync, A: Decoder](
2121
settings: JsonSchemaDeserializerSettings,
2222
client: SchemaRegistryClient
2323
)(implicit jsonSchema: json.Schema[A], tag: ClassTag[A]): F[ValueDeserializer[F, A]] =
2424
toJsonSchema[F, A](jsonSchema, settings.jsonSchemaId)
2525
.flatMap(create(settings, client, _))
26+
.map(identity)
2627

27-
def forKey[F[+_]: Sync, A: Decoder](
28+
def forKey[F[_]: Sync, A: Decoder](
2829
settings: JsonSchemaDeserializerSettings,
2930
client: SchemaRegistryClient
3031
)(implicit jsonSchema: json.Schema[A], tag: ClassTag[A]): F[KeyDeserializer[F, A]] =
3132
toJsonSchema[F, A](jsonSchema, settings.jsonSchemaId)
3233
.flatMap(create(settings, client, _))
34+
.map(identity)
3335

34-
def create[F[+_]: Sync, A: Decoder](
36+
def create[F[_]: Sync, A: Decoder](
3537
settings: JsonSchemaDeserializerSettings,
3638
client: SchemaRegistryClient,
3739
schema: JsonSchema

src/test/scala/io/kaizensolutions/jsonschema/JsonSchemaSerDesSpec.scala

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,14 +1,14 @@
11
package io.kaizensolutions.jsonschema
22

3-
import cats.effect._
4-
import cats.syntax.all._
3+
import cats.effect.*
4+
import cats.syntax.all.*
55
import com.dimafeng.testcontainers.DockerComposeContainer.ComposeFile
66
import com.dimafeng.testcontainers.munit.TestContainersForAll
77
import com.dimafeng.testcontainers.{DockerComposeContainer, ExposedService}
88
import fs2.Stream
9-
import fs2.kafka._
9+
import fs2.kafka.*
1010
import fs2.kafka.vulcan.SchemaRegistryClientSettings
11-
import io.circe.generic.semiauto._
11+
import io.circe.generic.semiauto.*
1212
import io.circe.{Codec, Decoder, Encoder}
1313
import io.confluent.kafka.schemaregistry.client.SchemaRegistryClient
1414
import io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException
@@ -232,7 +232,7 @@ class JsonSchemaSerDesSpec extends CatsEffectSuite with TestContainersForAll {
232232
assertion(produceElements)
233233
}
234234

235-
def consumeFromKafka[F[+_]: Async, A: Decoder: json.Schema: ClassTag](
235+
def consumeFromKafka[F[_]: Async, A: Decoder: json.Schema: ClassTag](
236236
fClient: F[SchemaRegistryClient],
237237
settings: JsonSchemaDeserializerSettings,
238238
groupId: String,

0 commit comments

Comments
 (0)