Skip to content

Commit 353fb0d

Browse files
committed
Cleanup/rename
1 parent f220dea commit 353fb0d

File tree

1 file changed

+2
-5
lines changed

1 file changed

+2
-5
lines changed

core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/async/FileAsyncRequestBodySplitHelper.java

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -128,9 +128,6 @@ private void checkCompletion(SimplePublisher<AsyncRequestBody> simplePublisher,
128128

129129
private void startNextRequestBody(SimplePublisher<AsyncRequestBody> simplePublisher) {
130130
int d = numAsyncRequestBodiesInFlight.decrementAndGet();
131-
if (d < 0) {
132-
throw new RuntimeException("Unexpected error occurred. numAsyncRequestBodiesInFlight is negative: " + d);
133-
}
134131
sendAsyncRequestBody(simplePublisher);
135132
}
136133

@@ -169,7 +166,7 @@ private final class FileAsyncRequestBodyWrapper implements AsyncRequestBody {
169166

170167
private final FileAsyncRequestBody fileAsyncRequestBody;
171168
private final SimplePublisher<AsyncRequestBody> simplePublisher;
172-
private final AtomicBoolean isDone = new AtomicBoolean(false);
169+
private final AtomicBoolean hasCompleted = new AtomicBoolean(false);
173170

174171
FileAsyncRequestBodyWrapper(FileAsyncRequestBody fileAsyncRequestBody,
175172
SimplePublisher<AsyncRequestBody> simplePublisher) {
@@ -190,7 +187,7 @@ public void subscribe(Subscriber<? super ByteBuffer> s) {
190187
}
191188

192189
private void startNextIfNeeded() {
193-
if (isDone.compareAndSet(false, true)) {
190+
if (hasCompleted.compareAndSet(false, true)) {
194191
startNextRequestBody(simplePublisher);
195192
}
196193
}

0 commit comments

Comments
 (0)