From 36622779b59dd5df9e0a76e240ba35796d991afa Mon Sep 17 00:00:00 2001
From: Krzysztof <krzysztof.witukiewicz@mgm-tp.com>
Date: Wed, 2 Apr 2025 09:42:29 +0200
Subject: [PATCH] OZG-7573 OZG-7991 Verify calling endTransfer() in test
---
.../common/binaryfile/StreamingFileSender.java | 2 +-
.../common/binaryfile/StreamingFileSenderTest.java | 13 ++++++-------
2 files changed, 7 insertions(+), 8 deletions(-)
diff --git a/ozgcloud-common-lib/src/main/java/de/ozgcloud/common/binaryfile/StreamingFileSender.java b/ozgcloud-common-lib/src/main/java/de/ozgcloud/common/binaryfile/StreamingFileSender.java
index 9d0440e..dc2af67 100644
--- a/ozgcloud-common-lib/src/main/java/de/ozgcloud/common/binaryfile/StreamingFileSender.java
+++ b/ozgcloud-common-lib/src/main/java/de/ozgcloud/common/binaryfile/StreamingFileSender.java
@@ -125,7 +125,7 @@ public abstract class StreamingFileSender<Q, S> {
}
}
- protected void endTransfer() {
+ void endTransfer() {
communicateEndOfTransfer();
done.set(true);
LOG.debug("File Transfer done.");
diff --git a/ozgcloud-common-lib/src/test/java/de/ozgcloud/common/binaryfile/StreamingFileSenderTest.java b/ozgcloud-common-lib/src/test/java/de/ozgcloud/common/binaryfile/StreamingFileSenderTest.java
index f369aab..32bd933 100644
--- a/ozgcloud-common-lib/src/test/java/de/ozgcloud/common/binaryfile/StreamingFileSenderTest.java
+++ b/ozgcloud-common-lib/src/test/java/de/ozgcloud/common/binaryfile/StreamingFileSenderTest.java
@@ -125,7 +125,7 @@ class StreamingFileSenderTest {
}
@Test
- void shouldCallSendMetaData() {
+ void shouldSendMetaData() {
fileSender.sendNext();
verify(fileSender).sendMetaData();
@@ -157,7 +157,7 @@ class StreamingFileSenderTest {
}
@Test
- void shouldCallSendChunk() {
+ void shouldSendChunk() {
fileSender.sendNextChunk();
verify(fileSender).sendChunk(chunkCaptor.capture(), eq(content.length));
@@ -176,18 +176,17 @@ class StreamingFileSenderTest {
}
@Test
- void shouldNotCallSendChunk() {
+ void shouldNotSendChunk() {
fileSender.sendNextChunk();
verify(fileSender, never()).sendChunk(any(), anyInt());
}
@Test
- @SneakyThrows
- void shouldCallCloseStreams() {
+ void shouldEndTransfer() {
fileSender.sendNextChunk();
- verify(fileSender).closeStreamReader();
+ verify(fileSender).endTransfer();
}
}
}
@@ -211,7 +210,7 @@ class StreamingFileSenderTest {
}
@Test
- void shouldCloseStreams() {
+ void shouldCloseStreamReader() {
fileSender.endTransfer();
verify(fileSender).closeStreamReader();
--
GitLab