From 6733460df22bd87831bd2a297bc5c43208c1f840 Mon Sep 17 00:00:00 2001 From: Pierre Ricadat Date: Fri, 3 Jan 2025 18:03:27 +0900 Subject: [PATCH] Make things public --- .../com/devsisters/shardcake/LocalSharding.scala | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/entities/src/main/scala/com/devsisters/shardcake/LocalSharding.scala b/entities/src/main/scala/com/devsisters/shardcake/LocalSharding.scala index 849990c..4655ea5 100644 --- a/entities/src/main/scala/com/devsisters/shardcake/LocalSharding.scala +++ b/entities/src/main/scala/com/devsisters/shardcake/LocalSharding.scala @@ -7,12 +7,12 @@ import zio.stream.ZStream object LocalSharding { - private trait LocalQueue { + trait LocalQueue { def localQueue: Queue[LocalQueueMessage] } - private sealed trait LocalQueueMessage - private object LocalQueueMessage { + sealed trait LocalQueueMessage + object LocalQueueMessage { case class SendMessage(request: BinaryMessage, response: Promise[Nothing, Option[Array[Byte]]]) extends LocalQueueMessage case class SendStream( @@ -29,7 +29,7 @@ object LocalSharding { ) extends LocalQueueMessage } - private val localQueue: ULayer[LocalQueue] = + val localQueue: ULayer[LocalQueue] = ZLayer( Queue .unbounded[LocalQueueMessage] @@ -40,7 +40,7 @@ object LocalSharding { ) ) - private val localPods: URLayer[LocalQueue, Pods] = + val localPods: URLayer[LocalQueue, Pods] = ZLayer { ZIO.serviceWith[LocalQueue](_.localQueue).map { queue => new Pods { @@ -86,7 +86,7 @@ object LocalSharding { } } - private val localServer: RLayer[Sharding with LocalQueue, Unit] = + val localServer: RLayer[Sharding with LocalQueue, Unit] = ZLayer.scoped { for { sharding <- ZIO.service[Sharding]