From ea049edf069b8dfa4f0994b2923a8cee85133e8e Mon Sep 17 00:00:00 2001 From: OZGCloud <ozgcloud@mgm-tp.com> Date: Thu, 21 Nov 2024 12:28:52 +0100 Subject: [PATCH] OZG-7143 delete flag check --- .../common/binaryfile/GrpcBinaryFileServerDownloader.java | 3 --- .../binaryfile/GrpcBinaryFileServerDownloaderTest.java | 7 ------- 2 files changed, 10 deletions(-) diff --git a/ozgcloud-common-lib/src/main/java/de/ozgcloud/common/binaryfile/GrpcBinaryFileServerDownloader.java b/ozgcloud-common-lib/src/main/java/de/ozgcloud/common/binaryfile/GrpcBinaryFileServerDownloader.java index 49f7260..b6bff4a 100644 --- a/ozgcloud-common-lib/src/main/java/de/ozgcloud/common/binaryfile/GrpcBinaryFileServerDownloader.java +++ b/ozgcloud-common-lib/src/main/java/de/ozgcloud/common/binaryfile/GrpcBinaryFileServerDownloader.java @@ -133,9 +133,6 @@ public class GrpcBinaryFileServerDownloader<T> { } void completeRequest() { - if (requestFinished.getAndSet(true)) { - return; - } LOG.debug("Complete download request"); closeInputStream(); callObserver.onCompleted(); diff --git a/ozgcloud-common-lib/src/test/java/de/ozgcloud/common/binaryfile/GrpcBinaryFileServerDownloaderTest.java b/ozgcloud-common-lib/src/test/java/de/ozgcloud/common/binaryfile/GrpcBinaryFileServerDownloaderTest.java index 215303f..2cda081 100644 --- a/ozgcloud-common-lib/src/test/java/de/ozgcloud/common/binaryfile/GrpcBinaryFileServerDownloaderTest.java +++ b/ozgcloud-common-lib/src/test/java/de/ozgcloud/common/binaryfile/GrpcBinaryFileServerDownloaderTest.java @@ -416,13 +416,6 @@ class GrpcBinaryFileServerDownloaderTest { setInputStreamField(inputStream); } - @Test - void shouldSetSendingFinished() { - downloader.completeRequest(); - - assertThat(getRequestFinished()).isTrue(); - } - @SneakyThrows @Test void shouldCallCloseInputStream() { -- GitLab