This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-connectors.git
The following commit(s) were added to refs/heads/main by this push:
new 897dabb50 rename test files with akka in the name (#1474)
897dabb50 is described below
commit 897dabb503a08d0037ff2e6916b3d56c93dee11c
Author: PJ Fanning <[email protected]>
AuthorDate: Mon Mar 2 19:25:41 2026 +0100
rename test files with akka in the name (#1474)
* rename test files with akka in the name
* Update ArchiveSpec.scala
---
file/src/test/java/docs/javadsl/ArchiveTest.java | 20 ++++++++++----------
.../{akka_full_color.svg => pekko_full_color.svg} | 0
...{akka_icon_reverse.svg => pekko_icon_reverse.svg} | 0
file/src/test/scala/docs/scaladsl/ArchiveSpec.scala | 14 +++++++-------
.../test/scala/docs/scaladsl/TarArchiveSpec.scala | 16 ++++++++--------
5 files changed, 25 insertions(+), 25 deletions(-)
diff --git a/file/src/test/java/docs/javadsl/ArchiveTest.java
b/file/src/test/java/docs/javadsl/ArchiveTest.java
index 91d9c9f1d..86f0453e4 100644
--- a/file/src/test/java/docs/javadsl/ArchiveTest.java
+++ b/file/src/test/java/docs/javadsl/ArchiveTest.java
@@ -74,8 +74,8 @@ public class ArchiveTest {
@Test
public void flowShouldCreateZIPArchive() throws Exception {
- ByteString fileContent1 =
readFileAsByteString(getFileFromResource("akka_full_color.svg"));
- ByteString fileContent2 =
readFileAsByteString(getFileFromResource("akka_icon_reverse.svg"));
+ ByteString fileContent1 =
readFileAsByteString(getFileFromResource("pekko_full_color.svg"));
+ ByteString fileContent2 =
readFileAsByteString(getFileFromResource("pekko_icon_reverse.svg"));
Source<ByteString, NotUsed> source1 = toSource(fileContent1);
Source<ByteString, NotUsed> source2 = toSource(fileContent2);
@@ -90,9 +90,9 @@ public class ArchiveTest {
// #sample-zip
Pair<ArchiveMetadata, Source<ByteString, NotUsed>> pair1 =
- Pair.create(ArchiveMetadata.create("akka_full_color.svg"), source1);
+ Pair.create(ArchiveMetadata.create("pekko_full_color.svg"), source1);
Pair<ArchiveMetadata, Source<ByteString, NotUsed>> pair2 =
- Pair.create(ArchiveMetadata.create("akka_icon_reverse.svg"), source2);
+ Pair.create(ArchiveMetadata.create("pekko_icon_reverse.svg"), source2);
Source<Pair<ArchiveMetadata, Source<ByteString, NotUsed>>, NotUsed> source
=
Source.from(Arrays.asList(pair1, pair2));
@@ -107,8 +107,8 @@ public class ArchiveTest {
Map<String, ByteString> inputFiles =
new HashMap<String, ByteString>() {
{
- put("akka_full_color.svg", fileContent1);
- put("akka_icon_reverse.svg", fileContent2);
+ put("pekko_full_color.svg", fileContent1);
+ put("pekko_icon_reverse.svg", fileContent2);
}
};
@@ -140,8 +140,8 @@ public class ArchiveTest {
@Test
public void flowShouldCreateTARArchive() throws Exception {
- Path filePath1 = getFileFromResource("akka_full_color.svg");
- Path filePath2 = getFileFromResource("akka_icon_reverse.svg");
+ Path filePath1 = getFileFromResource("pekko_full_color.svg");
+ Path filePath2 = getFileFromResource("pekko_icon_reverse.svg");
ByteString fileContent1 = readFileAsByteString(filePath1);
ByteString fileContent2 = readFileAsByteString(filePath2);
@@ -168,11 +168,11 @@ public class ArchiveTest {
Pair<TarArchiveMetadata, Source<ByteString, NotUsed>> pair1 =
Pair.create(
- TarArchiveMetadata.create("subdir", "akka_full_color.svg", size1,
lastModification),
+ TarArchiveMetadata.create("subdir", "pekko_full_color.svg", size1,
lastModification),
source1);
Pair<TarArchiveMetadata, Source<ByteString, NotUsed>> pair2 =
Pair.create(
- TarArchiveMetadata.create("akka_icon_reverse.svg", size2,
lastModification), source2);
+ TarArchiveMetadata.create("pekko_icon_reverse.svg", size2,
lastModification), source2);
Source<Pair<TarArchiveMetadata, Source<ByteString, NotUsed>>, NotUsed>
source =
Source.from(Arrays.asList(dir, pair1, pair2));
diff --git a/file/src/test/resources/akka_full_color.svg
b/file/src/test/resources/pekko_full_color.svg
similarity index 100%
rename from file/src/test/resources/akka_full_color.svg
rename to file/src/test/resources/pekko_full_color.svg
diff --git a/file/src/test/resources/akka_icon_reverse.svg
b/file/src/test/resources/pekko_icon_reverse.svg
similarity index 100%
rename from file/src/test/resources/akka_icon_reverse.svg
rename to file/src/test/resources/pekko_icon_reverse.svg
diff --git a/file/src/test/scala/docs/scaladsl/ArchiveSpec.scala
b/file/src/test/scala/docs/scaladsl/ArchiveSpec.scala
index 68a7c8cac..8e7aaa8cb 100644
--- a/file/src/test/scala/docs/scaladsl/ArchiveSpec.scala
+++ b/file/src/test/scala/docs/scaladsl/ArchiveSpec.scala
@@ -61,8 +61,8 @@ class ArchiveSpec
}
"archive file" in {
- val filePath1 = getPathFromResources("akka_full_color.svg")
- val filePath2 = getPathFromResources("akka_icon_reverse.svg")
+ val filePath1 = getPathFromResources("pekko_full_color.svg")
+ val filePath2 = getPathFromResources("pekko_icon_reverse.svg")
val fileStream1: Source[ByteString, Any] = FileIO.fromPath(filePath1)
val fileStream2: Source[ByteString, Any] = FileIO.fromPath(filePath2)
@@ -77,14 +77,14 @@ class ArchiveSpec
// #sample-zip
val filesStream = Source(
List(
- (ArchiveMetadata("akka_full_color.svg"), fileStream1),
- (ArchiveMetadata("akka_icon_reverse.svg"), fileStream2)))
+ (ArchiveMetadata("pekko_full_color.svg"), fileStream1),
+ (ArchiveMetadata("pekko_icon_reverse.svg"), fileStream2)))
val result = filesStream
.via(Archive.zip())
.runWith(FileIO.toPath(Paths.get("result.zip")))
// #sample-zip
- result.futureValue.count shouldBe 1178
+ result.futureValue.count shouldBe 1182
val resultFileContent =
FileIO.fromPath(Paths.get("result.zip")).runWith(Sink.fold(ByteString.empty)(_
++ _)).futureValue
@@ -101,8 +101,8 @@ class ArchiveSpec
.runWith(Sink.fold(ByteString.empty)(_ ++ _))
.futureValue
- unzipResultMap("akka_full_color.svg") shouldBe refFile1
- unzipResultMap("akka_icon_reverse.svg") shouldBe refFile2
+ unzipResultMap("pekko_full_color.svg") shouldBe refFile1
+ unzipResultMap("pekko_icon_reverse.svg") shouldBe refFile2
// cleanup
new File("result.zip").delete()
diff --git a/file/src/test/scala/docs/scaladsl/TarArchiveSpec.scala
b/file/src/test/scala/docs/scaladsl/TarArchiveSpec.scala
index da731fec8..61202b746 100644
--- a/file/src/test/scala/docs/scaladsl/TarArchiveSpec.scala
+++ b/file/src/test/scala/docs/scaladsl/TarArchiveSpec.scala
@@ -64,8 +64,8 @@ class TarArchiveSpec
}
"archive file" in {
- val filePath1 = getPathFromResources("akka_full_color.svg")
- val filePath2 = getPathFromResources("akka_icon_reverse.svg")
+ val filePath1 = getPathFromResources("pekko_full_color.svg")
+ val filePath2 = getPathFromResources("pekko_icon_reverse.svg")
val fileStream1: Source[ByteString, Any] = FileIO.fromPath(filePath1)
val fileStream2: Source[ByteString, Any] = FileIO.fromPath(filePath2)
val fileContent1 = ByteString(Files.readAllBytes(filePath1))
@@ -88,8 +88,8 @@ class TarArchiveSpec
val filesStream = Source(
List(
(TarArchiveMetadata.directory("subdir", lastModification),
Source.empty),
- (TarArchiveMetadata("subdir", "akka_full_color.svg", fileSize1,
lastModification), fileStream1),
- (TarArchiveMetadata("akka_icon_reverse.svg", fileSize2,
lastModification), fileStream2)))
+ (TarArchiveMetadata("subdir", "pekko_full_color.svg", fileSize1,
lastModification), fileStream1),
+ (TarArchiveMetadata("pekko_icon_reverse.svg", fileSize2,
lastModification), fileStream2)))
val result = filesStream
.via(Archive.tar())
@@ -107,12 +107,12 @@ class TarArchiveSpec
untar(Paths.get("result.tar").toRealPath(), "xf").foreach(
_ shouldBe Map(
- "subdir/akka_full_color.svg" -> fileContent1,
- "akka_icon_reverse.svg" -> fileContent2))
+ "subdir/pekko_full_color.svg" -> fileContent1,
+ "pekko_icon_reverse.svg" -> fileContent2))
untar(Paths.get("result.tar.gz").toRealPath(), "xfz").foreach(
_ shouldBe Map(
- "subdir/akka_full_color.svg" -> fileContent1,
- "akka_icon_reverse.svg" -> fileContent2))
+ "subdir/pekko_full_color.svg" -> fileContent1,
+ "pekko_icon_reverse.svg" -> fileContent2))
// cleanup
new File("result.tar").delete()
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
