Skip to content

Commit 78058b1

Browse files
committed
Clean up comments
1 parent 49c7ef2 commit 78058b1

File tree

2 files changed

+1
-7
lines changed

2 files changed

+1
-7
lines changed

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

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -68,8 +68,6 @@ public void exceptionOccurred(Throwable throwable) {
6868

6969
@Override
7070
public SplitResult<ResponseT, ResponseBytes<ResponseT>> split(SplittingTransformerConfiguration splitConfig) {
71-
// TODO - splitConfig not used - support this or log warning/update javdocs
72-
7371
CompletableFuture<ResponseBytes<ResponseT>> future = new CompletableFuture<>();
7472
SdkPublisher<AsyncResponseTransformer<ResponseT, ResponseT>> transformer =
7573
new ByteArraySplittingTransformer<>(this, future);

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

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -46,13 +46,9 @@ public class ByteArraySplittingTransformer<ResponseT> implements SdkPublisher<As
4646
private final AtomicInteger onNextSignalsSent = new AtomicInteger(0);
4747
private final AtomicReference<ResponseT> responseT = new AtomicReference<>();
4848

49-
/**
50-
* This publisher is used to send the bytes received from the downstream subscriber's transformers to a
51-
* {@link DelegatingBufferingSubscriber} that will buffer a number of bytes up to {@code maximumBufferSize}.
52-
*/
5349
private final SimplePublisher<ByteBuffer> publisherToUpstream = new SimplePublisher<>();
5450
/**
55-
* The amount requested by the downstream subscriber that is still left to fulfill. Updated. when the
51+
* The amount requested by the downstream subscriber that is still left to fulfill. Updated when the
5652
* {@link Subscription#request(long) request} method is called on the downstream subscriber's subscription. Corresponds to the
5753
* number of {@code AsyncResponseTransformer} that will be published to the downstream subscriber.
5854
*/

0 commit comments

Comments
 (0)