cleanups

Author: alextwoods

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

@@ -186,9 +186,7 @@ public void subscribe(Subscriber<? super ByteBuffer> s) {
                                 // finished successfully before onComplete. If this happens, doAfterOnComplete callback
                                 // will never be invoked, and if the current buffer is full, the publisher will stop
                                 // sending new FileAsyncRequestBody, leading to uncompleted future.
-                                .doAfterOnCancel(() -> {
-                                    startNextRequestBody(simplePublisher, position);
-                                })
+                                .doAfterOnCancel(() -> startNextRequestBody(simplePublisher, position))
                                 .subscribe(s);
         }
 

core/sdk-core/src/test/java/software/amazon/awssdk/core/internal/async/SplittingPublisherTestUtils.java

@@ -33,7 +33,6 @@ public static void verifyIndividualAsyncRequestBody(SdkPublisher<AsyncRequestBod
                                                         Path file,
                                                         int chunkSize) throws Exception {
 
-        long contentLength = file.toFile().length();
         List<CompletableFuture<ByteBuffer>> futures = new ArrayList<>();
         publisher.subscribe(requestBody -> {
             CompletableFuture<ByteBuffer> baosFuture = new CompletableFuture<>();
@@ -48,6 +47,7 @@ public static void verifyIndividualAsyncRequestBody(SdkPublisher<AsyncRequestBod
             futures.add(baosFuture);
         }).get(5, TimeUnit.SECONDS);
 
+        long contentLength = file.toFile().length();
         Assertions.assertThat(futures.size()).isEqualTo((int) Math.ceil(contentLength / (double) chunkSize));
 
         for (int i = 0; i < futures.size(); i++) {