Skip to content

Commit

Permalink
scalafmt
Browse files Browse the repository at this point in the history
  • Loading branch information
DanielTavaresA committed May 14, 2024
1 parent 9bb26f6 commit 43639b2
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -82,8 +82,8 @@ final case class GossipManager(
}
} else {
log.info(s"Unexpected match for active gossip. Response with id ${response.id} matched with ${activeGossipPeers.size} entries")
//removes duplicate entries to come back to a stable state
activeGossipPeers.foreach{ (rumorRpc, _) =>
// removes duplicate entries to come back to a stable state
activeGossipPeers.foreach { (rumorRpc, _) =>
activeGossipProtocol -= rumorRpc
}
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -112,7 +112,7 @@ class GossipManagerSuite extends TestKit(ActorSystem("GossipManagerSuiteActorSys

Await.result(outputRumor, duration)

//checks that only one peers received the rumor
// checks that only one peers received the rumor
val received = peers.map(_.receiveOne(duration))
received.count(_ != null) shouldBe 1
val remainingPeers = peers.lazyZip(received).filter((_, recv) => recv == null).map(_._1)
Expand Down

0 comments on commit 43639b2

Please sign in to comment.