using objects

akka · Dec 17, 2024 · e8de324 · e8de324
1 parent 9bfd656
commit e8de324
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/akka-javasdk/src/main/scala/akka/javasdk/impl/consumer/ConsumerImpl.scala b/akka-javasdk/src/main/scala/akka/javasdk/impl/consumer/ConsumerImpl.scala
@@ -112,7 +112,7 @@ private[impl] final class ConsumerImpl[C <: Consumer](
             handleUnexpectedException(message, ex)
           }
       case IgnoreEffect =>
-        Future.successful(new SpiConsumer.IgnoreEffect)
+        Future.successful(SpiConsumer.IgnoreEffect)
       case unknown =>
         throw new IllegalArgumentException(s"Unknown TimedAction.Effect type ${unknown.getClass}")
     }

diff --git a/akka-javasdk/src/main/scala/akka/javasdk/impl/timedaction/TimedActionImpl.scala b/akka-javasdk/src/main/scala/akka/javasdk/impl/timedaction/TimedActionImpl.scala
@@ -125,7 +125,7 @@ private[impl] final class TimedActionImpl[TA <: TimedAction](
   private def toSpiEffect(command: Command, effect: TimedAction.Effect): Future[Effect] = {
     effect match {
       case ReplyEffect(_) => //FIXME remove meta, not used in the reply
-        Future.successful(new SpiTimedAction.SuccessEffect)
+        Future.successful(SpiTimedAction.SuccessEffect)
       case AsyncEffect(futureEffect) =>
         futureEffect
           .flatMap { effect => toSpiEffect(command, effect) }

diff --git a/akka-javasdk/src/test/scala/akka/javasdk/impl/timedaction/TimedActionImplSpec.scala b/akka-javasdk/src/test/scala/akka/javasdk/impl/timedaction/TimedActionImplSpec.scala
@@ -87,7 +87,7 @@ class TimedActionImplSpec
             new SpiTimedAction.Command("MyMethod", Some(new BytesPayload(ByteString.empty, "")), SpiMetadata.empty))
           .futureValue
 
-      reply shouldBe an[SpiTimedAction.SuccessEffect]
+      reply shouldBe an[SpiTimedAction.SuccessEffect.type]
     }
 
     "turn thrown command handler exceptions into failure responses" in {