Skip to content

Commit 7e868ad

Browse files
committed
Handled review comment
1 parent 1c38faf commit 7e868ad

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

services/sqs/src/main/java/software/amazon/awssdk/services/sqs/internal/batchmanager/RequestBatchManager.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -163,12 +163,11 @@ private void performScheduledFlush(String batchKey) {
163163
public void close() {
164164
requestsAndResponsesMaps.forEach((batchKey, batchBuffer) -> {
165165
requestsAndResponsesMaps.cancelScheduledFlush(batchKey);
166-
Map<String, BatchingExecutionContext<RequestT, ResponseT>> extractedEntries =
167-
requestsAndResponsesMaps.extractBatchIfReady(batchKey);
166+
Map<String, BatchingExecutionContext<RequestT, ResponseT>>
167+
extractedEntries = requestsAndResponsesMaps.extractBatchIfReady(batchKey);
168168

169169
while (!extractedEntries.isEmpty()) {
170170
flushBuffer(batchKey, extractedEntries);
171-
extractedEntries = requestsAndResponsesMaps.extractBatchIfReady(batchKey);
172171
}
173172

174173
});

0 commit comments

Comments
 (0)