Skip to content

Commit

Permalink
Make things public
Browse files Browse the repository at this point in the history
  • Loading branch information
ghostdogpr committed Jan 3, 2025
1 parent 1a94654 commit 6733460
Showing 1 changed file with 6 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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(
Expand All @@ -29,7 +29,7 @@ object LocalSharding {
) extends LocalQueueMessage
}

private val localQueue: ULayer[LocalQueue] =
val localQueue: ULayer[LocalQueue] =
ZLayer(
Queue
.unbounded[LocalQueueMessage]
Expand All @@ -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 {
Expand Down Expand Up @@ -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]
Expand Down

0 comments on commit 6733460

Please sign in to comment.