Skip to content

Commit

Permalink
Formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
Ilya Surkov committed Nov 21, 2022
1 parent 2d31d92 commit f01fdce
Showing 1 changed file with 9 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -46,13 +46,17 @@ class ClusterShardingLocalTest extends AsyncFunSuite with ActorSuite with Matche

// Allocation strategy that doesn't use ActorSystem and Cluster extension (as opposed to Akka built-in strategies)
val noopAllocationStrategy = new ShardAllocationStrategy {
override def allocateShard(requester: ActorRef,
shardId: ShardId,
currentShardAllocations: Map[ActorRef, IndexedSeq[ShardId]]): Future[ActorRef] =
override def allocateShard(
requester: ActorRef,
shardId: ShardId,
currentShardAllocations: Map[ActorRef, IndexedSeq[ShardId]]
): Future[ActorRef] =
Future.successful(requester)

override def rebalance(currentShardAllocations: Map[ActorRef, IndexedSeq[ShardId]],
rebalanceInProgress: Set[ShardId]): Future[Set[ShardId]] =
override def rebalance(
currentShardAllocations: Map[ActorRef, IndexedSeq[ShardId]],
rebalanceInProgress: Set[ShardId]
): Future[Set[ShardId]] =
Future.successful(Set.empty)
}

Expand Down

0 comments on commit f01fdce

Please sign in to comment.