@@ -7,12 +7,12 @@ import zio.stream.ZStream
7
7
8
8
object LocalSharding {
9
9
10
- private trait LocalQueue {
10
+ trait LocalQueue {
11
11
def localQueue : Queue [LocalQueueMessage ]
12
12
}
13
13
14
- private sealed trait LocalQueueMessage
15
- private object LocalQueueMessage {
14
+ sealed trait LocalQueueMessage
15
+ object LocalQueueMessage {
16
16
case class SendMessage (request : BinaryMessage , response : Promise [Nothing , Option [Array [Byte ]]])
17
17
extends LocalQueueMessage
18
18
case class SendStream (
@@ -29,7 +29,7 @@ object LocalSharding {
29
29
) extends LocalQueueMessage
30
30
}
31
31
32
- private val localQueue : ULayer [LocalQueue ] =
32
+ val localQueue : ULayer [LocalQueue ] =
33
33
ZLayer (
34
34
Queue
35
35
.unbounded[LocalQueueMessage ]
@@ -40,7 +40,7 @@ object LocalSharding {
40
40
)
41
41
)
42
42
43
- private val localPods : URLayer [LocalQueue , Pods ] =
43
+ val localPods : URLayer [LocalQueue , Pods ] =
44
44
ZLayer {
45
45
ZIO .serviceWith[LocalQueue ](_.localQueue).map { queue =>
46
46
new Pods {
@@ -86,7 +86,7 @@ object LocalSharding {
86
86
}
87
87
}
88
88
89
- private val localServer : RLayer [Sharding with LocalQueue , Unit ] =
89
+ val localServer : RLayer [Sharding with LocalQueue , Unit ] =
90
90
ZLayer .scoped {
91
91
for {
92
92
sharding <- ZIO .service[Sharding ]
0 commit comments