From da843dbdce3f96be780916fafd94f7d7e39018dc Mon Sep 17 00:00:00 2001 From: Benjamin Voiturier Date: Wed, 20 Nov 2024 13:54:43 +0100 Subject: [PATCH] chore: run scalafmt Signed-off-by: Benjamin Voiturier --- .../identus/shared/messaging/MessagingService.scala | 2 +- .../shared/messaging/kafka/InMemoryMessagingService.scala | 4 +++- 2 files changed, 4 insertions(+), 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 index ffa8855136..3ef20e3dd9 100644 --- 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/shared/core/src/main/scala/org/hyperledger/identus/shared/messaging/kafka/InMemoryMessagingService.scala b/shared/core/src/main/scala/org/hyperledger/identus/shared/messaging/kafka/InMemoryMessagingService.scala index 0d5fd3f4dc..8577ef072c 100644 --- a/shared/core/src/main/scala/org/hyperledger/identus/shared/messaging/kafka/InMemoryMessagingService.scala +++ b/shared/core/src/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)) }