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 a9dd11646 csv: use ByteString.empty (#666)
a9dd11646 is described below
commit a9dd1164690e8c2e353250936b1ac9ecb6b5ffeb
Author: PJ Fanning <[email protected]>
AuthorDate: Sun May 19 15:54:52 2024 +0100
csv: use ByteString.empty (#666)
---
.../pekko/stream/connectors/csv/impl/CsvToMapJavaStage.scala | 2 +-
.../pekko/stream/connectors/csv/impl/CsvToMapStage.scala | 2 +-
csv/src/test/scala/docs/scaladsl/CsvToMapSpec.scala | 12 ++++++------
3 files changed, 8 insertions(+), 8 deletions(-)
diff --git
a/csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvToMapJavaStage.scala
b/csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvToMapJavaStage.scala
index 3bdd4ec9f..a7cbd8ca8 100644
---
a/csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvToMapJavaStage.scala
+++
b/csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvToMapJavaStage.scala
@@ -146,7 +146,7 @@ import pekko.util.ByteString
customFieldValuePlaceholder,
headerPlaceholder) {
- override val fieldValuePlaceholder: ByteString = ByteString("")
+ override val fieldValuePlaceholder: ByteString = ByteString.empty
override protected def transformElements(elements:
ju.Collection[ByteString]): ju.Collection[ByteString] =
elements
diff --git
a/csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvToMapStage.scala
b/csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvToMapStage.scala
index 5a12e4da2..685fc487d 100644
---
a/csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvToMapStage.scala
+++
b/csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvToMapStage.scala
@@ -121,7 +121,7 @@ import scala.collection.immutable
customFieldValuePlaceholder,
headerPlaceholder) {
- override val fieldValuePlaceholder: ByteString = ByteString("")
+ override val fieldValuePlaceholder: ByteString = ByteString.empty
override protected def transformElements(elements:
immutable.Seq[ByteString]): immutable.Seq[ByteString] = elements
diff --git a/csv/src/test/scala/docs/scaladsl/CsvToMapSpec.scala
b/csv/src/test/scala/docs/scaladsl/CsvToMapSpec.scala
index 7ae50136f..55d956015 100644
--- a/csv/src/test/scala/docs/scaladsl/CsvToMapSpec.scala
+++ b/csv/src/test/scala/docs/scaladsl/CsvToMapSpec.scala
@@ -340,13 +340,13 @@ class CsvToMapSpec extends CsvSpec {
Map("eins" -> ByteString("11"),
"zwei" -> ByteString("12"),
"drei" -> ByteString("13"),
- "vier" -> ByteString(""),
- "fünt" -> ByteString("")),
+ "vier" -> ByteString.empty,
+ "fünt" -> ByteString.empty),
Map("eins" -> ByteString("21"),
"zwei" -> ByteString("22"),
"drei" -> ByteString("23"),
- "vier" -> ByteString(""),
- "fünt" -> ByteString(""))))
+ "vier" -> ByteString.empty,
+ "fünt" -> ByteString.empty)))
// #header-line
}
@@ -408,7 +408,7 @@ class CsvToMapSpec extends CsvSpec {
result should be(
Seq(
Map("eins" -> ByteString("11"), "zwei" -> ByteString("12"),
"MyCustomHeader0" -> ByteString("13")),
- Map("eins" -> ByteString("21"), "zwei" -> ByteString("22"),
"MyCustomHeader0" -> ByteString(""))))
+ Map("eins" -> ByteString("21"), "zwei" -> ByteString("22"),
"MyCustomHeader0" -> ByteString.empty)))
// #header-line
}
@@ -442,7 +442,7 @@ class CsvToMapSpec extends CsvSpec {
"fünt" -> ByteString("missing")),
Map("eins" -> ByteString("21"),
"zwei" -> ByteString("22"),
- "drei" -> ByteString(""),
+ "drei" -> ByteString.empty,
"fünt" -> ByteString("missing"))))
// #header-line
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
