luciano/amazon-kinesis-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fixed typo and made for loop into stream for getting available leases

Browse source
This commit is contained in:
Brendan Lynch 2024-04-30 15:13:51 -07:00
parent cfd23777cd
commit 55b2e5da34
2 changed files with 4 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/Lease.java
View file

@ -174,7 +174,7 @@ public class Lease {
/** /**
* @param leaseDurationNanos duration of lease in nanoseconds * @param leaseDurationNanos duration of lease in nanoseconds
* @param asOfNanos time in nanoseconds to check expiration as-of * @param asOfNanos time in nanoseconds to check expiration as-of
* @return true if lease lease is ready te taken * @return true if lease lease is ready to be taken
*/ */
public boolean isAvailable(long leaseDurationNanos, long asOfNanos) { public boolean isAvailable(long leaseDurationNanos, long asOfNanos) {
return isUnassigned() || isExpired(leaseDurationNanos, asOfNanos); return isUnassigned() || isExpired(leaseDurationNanos, asOfNanos);

12
amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseTaker.java
View file

@ -373,15 +373,9 @@ public class DynamoDBLeaseTaker implements LeaseTaker {
* @return list of leases that available as of our last scan. * @return list of leases that available as of our last scan.
*/ */
private List<Lease> getAvailableLeases() { private List<Lease> getAvailableLeases() {
List<Lease> availableLeases = new ArrayList<>(); return allLeases.values().stream()
.filter(lease->lease.isAvailable(leaseDurationNanos, lastScanTimeNanos))
for (Lease lease : allLeases.values()) { .collect(Collectors.toList());
if (lease.isAvailable(leaseDurationNanos, lastScanTimeNanos)) {
availableLeases.add(lease);
}
}
return availableLeases;
} }
/** /**