Merge pull request #834 from fd4s/fix-serde-tests

Fix serde tests for CE3.3
fd4s · Jan 8, 2022 · 74d630d · 74d630d
2 parents 85db114 + f388bb3
commit 74d630d
Show file tree

Hide file tree

Showing 4 changed files with 13 additions and 7 deletions.
diff --git a/docs/src/main/mdoc/modules.md b/docs/src/main/mdoc/modules.md
@@ -146,6 +146,7 @@ codecs against a [schema registry](https://docs.confluent.io/platform/current/sc
 A usage example:
 
 ```scala mdoc:reset
+import cats.effect.unsafe.implicits.global
 import fs2.kafka.vulcan.SchemaRegistryClientSettings
 import org.apache.avro.SchemaCompatibility.SchemaCompatibilityType
 import fs2.kafka.vulcan.testkit.SchemaSuite

diff --git a/modules/core/src/main/scala-2.12/fs2/kafka/internal/converters.scala b/modules/core/src/main/scala-2.12/fs2/kafka/internal/converters.scala
@@ -1,5 +1,5 @@
 /*
- * Copyright 2018-2021 OVO Energy Limited
+ * Copyright 2018-2022 OVO Energy Limited
  *
  * SPDX-License-Identifier: Apache-2.0
  */

diff --git a/modules/core/src/test/scala/fs2/kafka/DeserializerSpec.scala b/modules/core/src/test/scala/fs2/kafka/DeserializerSpec.scala
@@ -1,18 +1,21 @@
 package fs2.kafka
 
+import cats.Eq
 import cats.effect.IO
 import cats.laws.discipline._
 
 final class DeserializerSpec extends BaseCatsSpec {
+  import cats.effect.unsafe.implicits.global
+
   checkAll(
     "Deserializer[IO, *]", {
-      implicit val ticker = Ticker()
+      // use of Ticker causes an error since CE3.3.0
+      // implicit val ticker = Ticker()
+      implicit def eq[A: Eq]: Eq[IO[A]] = Eq.by(_.attempt.unsafeRunSync())
       MonadErrorTests[Deserializer[IO, *], Throwable].monadError[String, String, String]
     }
   )
 
-  import cats.effect.unsafe.implicits.global
-
   test("Deserializer#attempt") {
     forAll { (topic: String, headers: Headers, i: Int) =>
       val bytes = Serializer[IO, Int].serialize(topic, headers, i).unsafeRunSync()

diff --git a/modules/core/src/test/scala/fs2/kafka/SerializerSpec.scala b/modules/core/src/test/scala/fs2/kafka/SerializerSpec.scala
@@ -9,15 +9,17 @@ import org.scalacheck.Arbitrary
 import org.scalatest._
 
 final class SerializerSpec extends BaseCatsSpec {
+  import cats.effect.unsafe.implicits.global
+
   checkAll(
     "Serializer[IO, *]", {
-      implicit val ticker = Ticker()
+      // use of Ticker causes an error since CE3.3.0
+      // implicit val ticker = Ticker()
+      implicit val eq: Eq[IO[Array[Byte]]] = Eq.by(_.unsafeRunSync())
       ContravariantTests[Serializer[IO, *]].contravariant[String, String, String]
     }
   )
 
-  import cats.effect.unsafe.implicits.global
-
   test("Serializer#mapBytes") {
     val serializer =
       Serializer