Skip to content

Commit

Permalink
fmt
Browse files Browse the repository at this point in the history
  • Loading branch information
Pierre Ricadat committed Jul 6, 2019
1 parent 0693306 commit fca3ae4
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -90,7 +90,7 @@ class ShardingSpec extends FlatSpec with Matchers with DefaultRuntime {
case "set" => ZIO.accessM[Entity[Unit]](_.state.set(Some(())))
case "get" => ZIO.accessM[Entity[Unit]](_.state.get.flatMap(s => p.succeed(s).unit))
case "die" => ZIO.accessM[Entity[Unit]](_.stop)
}
}
sharding <- Sharding.start(shardName, onMessage).provide(sys)
_ <- sharding.send(shardId, "set")
_ <- sharding.send(shardId, "die")
Expand Down

0 comments on commit fca3ae4

Please sign in to comment.