File tree Expand file tree Collapse file tree 4 files changed +6
-6
lines changed
entities/src/test/scala/com/devsisters/shardcake Expand file tree Collapse file tree 4 files changed +6
-6
lines changed Original file line number Diff line number Diff line change @@ -22,7 +22,7 @@ object ShardingSpec extends DefaultRunnableSpec {
2222 def spec : ZSpec [TestEnvironment , Throwable ] =
2323 suite(" ShardingSpec" )(
2424 testM(" Send message to entities" ) {
25- (Sharding .registerManaged *> Sharding . registerEntity(Counter , behavior)).use { _ =>
25+ (Sharding .registerEntity(Counter , behavior) *> Sharding .registerManaged ).use { _ =>
2626 for {
2727 counter <- Sharding .messenger(Counter )
2828 _ <- counter.sendDiscard(" c1" )(IncrementCounter )
Original file line number Diff line number Diff line change @@ -16,7 +16,7 @@ object GuildApp extends zio.App {
1616 .toLayer
1717
1818 val program =
19- Sharding .registerEntity(Guild , behavior).use { _ =>
19+ ( Sharding .registerEntity(Guild , behavior) *> Sharding .registerManaged ).use { _ =>
2020 Sharding .messenger(Guild ).map { guild =>
2121 for {
2222 user1 <- random.nextUUID.map(_.toString)
@@ -41,5 +41,5 @@ object GuildApp extends zio.App {
4141 val layer = sharding ++ service ++ redis
4242
4343 def run (args : List [String ]): URIO [ZEnv , ExitCode ] =
44- Sharding .registerManaged.use(_ => program) .provideLayer(layer).exitCode
44+ program.provideLayer(layer).exitCode
4545}
Original file line number Diff line number Diff line change @@ -10,7 +10,7 @@ import zio.random.Random
1010
1111object GuildApp extends zio.App {
1212 val program =
13- Sharding .registerEntity(Guild , behavior).use { _ =>
13+ ( Sharding .registerEntity(Guild , behavior) *> Sharding .registerManaged ).use { _ =>
1414 Sharding .messenger(Guild ).map { guild =>
1515 for {
1616 _ <- guild.send(" guild1" )(Join (" user1" , _)).debug
@@ -34,5 +34,5 @@ object GuildApp extends zio.App {
3434 val layer = sharding ++ service
3535
3636 def run (args : List [String ]): URIO [ZEnv , ExitCode ] =
37- Sharding .registerManaged.use(_ => program) .provideLayer(layer).exitCode
37+ program.provideLayer(layer).exitCode
3838}
Original file line number Diff line number Diff line change @@ -83,7 +83,7 @@ object EndToEndSpec extends DefaultRunnableSpec {
8383 def spec =
8484 suite(" EndToEndSpec" )(
8585 testM(" Send message to entities" ) {
86- (Sharding .registerManaged *> Sharding . registerEntity(Guild , GuildBehavior .behavior)).use { _ =>
86+ (Sharding .registerEntity(Guild , GuildBehavior .behavior) *> Sharding .registerManaged ).use { _ =>
8787 for {
8888 guild <- Sharding .messenger(Guild )
8989 _ <- guild.send(" guild1" )(Join (" user1" , _))
You can’t perform that action at this time.
0 commit comments