chore: run scalafmt

Signed-off-by: Benjamin Voiturier <benjamin.voiturier@iohk.io>
hyperledger · Nov 20, 2024 · da843db · da843db
1 parent eff93ab
commit da843db
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/shared/core/src/main/scala/org/hyperledger/identus/shared/messaging/MessagingService.scala b/shared/core/src/main/scala/org/hyperledger/identus/shared/messaging/MessagingService.scala
@@ -1,7 +1,7 @@
 package org.hyperledger.identus.shared.messaging
 
 import org.hyperledger.identus.shared.messaging.kafka.{InMemoryMessagingService, ZKafkaMessagingServiceImpl}
-import zio.{Cause, Duration, EnvironmentTag, RIO, RLayer, Scope, Task, URIO, URLayer, ZIO, ZLayer, durationInt}
+import zio.{durationInt, Cause, Duration, EnvironmentTag, RIO, RLayer, Scope, Task, URIO, URLayer, ZIO, ZLayer}
 
 import java.time.Instant
 trait MessagingService {

diff --git a/.../main/scala/org/hyperledger/identus/shared/messaging/kafka/InMemoryMessagingService.scala b/.../main/scala/org/hyperledger/identus/shared/messaging/kafka/InMemoryMessagingService.scala
@@ -19,7 +19,9 @@ class InMemoryMessagingService(
     ]
 ) extends MessagingService {
 
-  override def makeConsumer[K, V](groupId: String)(using kSerde: Serde[K], vSerde: Serde[V]): RIO[Scope, Consumer[K, V]] = {
+  override def makeConsumer[K, V](
+      groupId: String
+  )(using kSerde: Serde[K], vSerde: Serde[V]): RIO[Scope, Consumer[K, V]] = {
     ZIO.succeed(new InMemoryConsumer[K, V](groupId, topicQueues, processedMessagesMap))
   }