This is an automated email from the ASF dual-hosted git repository.
pjfanning pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko.git
The following commit(s) were added to refs/heads/main by this push:
new cd980eac30 use decodeString(StandardCharsets.UTF_8) (#3155)
cd980eac30 is described below
commit cd980eac30546f317cfd6239fd85f6d7ba8b1e19
Author: PJ Fanning <[email protected]>
AuthorDate: Tue Jun 23 13:46:38 2026 +0100
use decodeString(StandardCharsets.UTF_8) (#3155)
---
docs/src/test/java/jdocs/io/JavaUdpMulticast.java | 3 ++-
docs/src/test/scala/docs/io/ScalaUdpMulticast.scala | 3 ++-
2 files changed, 4 insertions(+), 2 deletions(-)
diff --git a/docs/src/test/java/jdocs/io/JavaUdpMulticast.java
b/docs/src/test/java/jdocs/io/JavaUdpMulticast.java
index b33eb95f30..e482f73f6b 100644
--- a/docs/src/test/java/jdocs/io/JavaUdpMulticast.java
+++ b/docs/src/test/java/jdocs/io/JavaUdpMulticast.java
@@ -20,6 +20,7 @@ import java.net.InetSocketAddress;
import java.net.NetworkInterface;
import java.net.StandardProtocolFamily;
import java.nio.channels.DatagramChannel;
+import java.nio.charset.StandardCharsets;
import java.util.ArrayList;
import java.util.List;
import org.apache.pekko.actor.AbstractActor;
@@ -100,7 +101,7 @@ public class JavaUdpMulticast {
.match(
Udp.Received.class,
received -> {
- final String txt = received.data().decodeString("utf-8");
+ final String txt =
received.data().decodeString(StandardCharsets.UTF_8);
log.info("Received '{}' from {}", txt, received.sender());
sink.tell(txt, getSelf());
})
diff --git a/docs/src/test/scala/docs/io/ScalaUdpMulticast.scala
b/docs/src/test/scala/docs/io/ScalaUdpMulticast.scala
index c1d4752e19..65c8ca5998 100644
--- a/docs/src/test/scala/docs/io/ScalaUdpMulticast.scala
+++ b/docs/src/test/scala/docs/io/ScalaUdpMulticast.scala
@@ -16,6 +16,7 @@ package docs.io
import java.net.{ InetAddress, InetSocketAddress, NetworkInterface,
StandardProtocolFamily }
import java.net.DatagramSocket
import java.nio.channels.DatagramChannel
+import java.nio.charset.StandardCharsets
import org.apache.pekko.actor.{ Actor, ActorLogging, ActorRef }
import org.apache.pekko.io.Inet.{ DatagramChannelCreator, SocketOptionV2 }
@@ -51,7 +52,7 @@ class Listener(iface: String, group: String, port: Int, sink:
ActorRef) extends
log.info("Bound to {}", to)
sink ! b
case Udp.Received(data, remote) =>
- val msg = data.decodeString("utf-8")
+ val msg = data.decodeString(StandardCharsets.UTF_8)
log.info("Received '{}' from {}", msg, remote)
sink ! msg
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
