raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Tiny style fix

Browse source
This commit is contained in:
Yik San Chan 2020-09-17 18:33:41 -07:00
parent 58ca04ec70
commit 82361c0694
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-cluster/src/main/scala/akka/cluster/Reachability.scala
View file

@ -210,7 +210,7 @@ private[cluster] class Reachability private (
Reachability(newRecords, newVersions)
}
def filterRecords(f: Record => Boolean) =
def filterRecords(f: Record => Boolean): Reachability =
Reachability(records.filter(f), versions)
def status(observer: UniqueAddress, subject: UniqueAddress): ReachabilityStatus =
@ -278,7 +278,7 @@ private[cluster] class Reachability private (
case (subject, records) if records.exists(_.status == Unreachable) =>
val observers: Set[UniqueAddress] =
records.iterator.collect { case r if r.status == Unreachable => r.observer }.to(immutable.Set)
(subject -> observers)
subject -> observers
}
}