You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@plc4x.apache.org by jm...@apache.org on 2018/02/20 00:51:39 UTC

[incubator-plc4x] 01/02: simplify

This is an automated email from the ASF dual-hosted git repository.

jmclean pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-plc4x.git

commit ca98538aec2ed2959255cd881852f5cb57e42ed9
Author: Justin Mclean <jm...@apache.org>
AuthorDate: Tue Feb 20 11:51:04 2018 +1100

    simplify
---
 .../java/org/apache/plc4x/java/examples/kafkabridge/KafkaBridge.java  | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/examples/kafka-bridge/src/main/java/org/apache/plc4x/java/examples/kafkabridge/KafkaBridge.java b/examples/kafka-bridge/src/main/java/org/apache/plc4x/java/examples/kafkabridge/KafkaBridge.java
index 9466419..509a394 100644
--- a/examples/kafka-bridge/src/main/java/org/apache/plc4x/java/examples/kafkabridge/KafkaBridge.java
+++ b/examples/kafka-bridge/src/main/java/org/apache/plc4x/java/examples/kafkabridge/KafkaBridge.java
@@ -94,9 +94,7 @@ public class KafkaBridge {
         TStream<Byte> source = top.poll(plcSupplier, config.getPollingInterval(), TimeUnit.MILLISECONDS);
 
         // Convert the byte into a string.
-        TStream<String> stringSource = source.map(value -> {
-            return Byte.toString(value);
-        });
+        TStream<String> stringSource = source.map(value -> Byte.toString(value));
 
         // Publish the stream to the topic.  The String tuple is the message value.
         kafka.publish(stringSource, config.getKafkaConfig().getTopicName());

-- 
To stop receiving notification emails like this one, please contact
jmclean@apache.org.