Adapt code to new wartremover rules

endless4s · Oct 10, 2024 · 3eca552 · 3eca552
1 parent 5b4a3dd
commit 3eca552
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/lib/src/main/scala/endless/transaction/Coordinator.scala b/lib/src/main/scala/endless/transaction/Coordinator.scala
@@ -66,5 +66,5 @@ trait Coordinator[F[_], TID, BID, Q, R] {
 }
 
 object Coordinator {
-  object TransactionAlreadyExists extends Exception("Transaction with the given ID already exists")
+  class TransactionAlreadyExists extends Exception("Transaction with the given ID already exists")
 }
diff --git a/lib/src/main/scala/endless/transaction/impl/logic/ShardedCoordinator.scala b/lib/src/main/scala/endless/transaction/impl/logic/ShardedCoordinator.scala
@@ -56,7 +56,7 @@ private[transaction] final class ShardedCoordinator[F[_]: Logger, TID, BID, Q, R
         case Left(_) =>
           Resource.eval(Logger[F].warn(show"Transaction $id already exists")) >> Resource
             .raiseError[F, Transaction[F, BID, Q, R], Throwable](
-              Coordinator.TransactionAlreadyExists
+              new Coordinator.TransactionAlreadyExists
             )
       }
 

diff --git a/lib/src/test/scala/endless/transaction/impl/logic/ShardedCoordinatorSuite.scala b/lib/src/test/scala/endless/transaction/impl/logic/ShardedCoordinatorSuite.scala
@@ -139,7 +139,7 @@ class ShardedCoordinatorSuite
           def entityFor(id: TID): TransactionAlg[IO, TID, BID, Q, R] = testTransaction
         }
       val coordinator = new ShardedCoordinator(sharding)
-      interceptIO[Coordinator.TransactionAlreadyExists.type](
+      interceptIO[Coordinator.TransactionAlreadyExists](
         coordinator
           .create(tid, query, branches.head, branches.tail*)
           .use_