fix QueryLogSuite

typelevel · Jan 31, 2025 · cde7e77 · cde7e77
1 parent 3645b8d
commit cde7e77
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/modules/core/src/test/scala/doobie/util/QueryLogSuite.scala b/modules/core/src/test/scala/doobie/util/QueryLogSuite.scala
@@ -16,22 +16,22 @@ import doobie.util.update.Update
 
 class QueryLogSuite extends munit.CatsEffectSuite with QueryLogSuitePlatform {
 
-  val logEventRef: IO[Ref[IO, LogEvent]] =
-    Ref.of[IO, LogEvent](null)
+  val logEventRef: Ref[IO, LogEvent] =
+    Ref.of[IO, LogEvent](null).unsafeRunSync()
 
   val xa = Transactor.fromDriverManager[IO](
     "org.h2.Driver",
     "jdbc:h2:mem:queryspec;DB_CLOSE_DELAY=-1",
     "sa",
     "",
-    logHandler = Some(ev => logEventRef.unsafeRunSync().set(ev))
+    logHandler = Some(ev => logEventRef.set(ev))
   )
 
   def eventForCIO[A](cio: ConnectionIO[A]): IO[LogEvent] = {
     for {
-      _ <- logEventRef.flatMap(_.set(null))
+      _ <- logEventRef.set(null)
       _ <- cio.transact(xa).attempt
-      log <- logEventRef.flatMap(_.get)
+      log <- logEventRef.get
     } yield log
   }