From fd93f81f8757bff2388af556c56618667f78a21d Mon Sep 17 00:00:00 2001 From: Matthew de Detrich Date: Wed, 1 Nov 2023 08:15:03 +0100 Subject: [PATCH] Remove useless condition --- .../stream/connectors/mqtt/streaming/impl/RequestState.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/RequestState.scala b/mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/RequestState.scala index da54ba8e3..23b9ab79f 100644 --- a/mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/RequestState.scala +++ b/mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/RequestState.scala @@ -646,7 +646,7 @@ object Topics { val tnHead = tn.charAt(0) if (tfnHead == '/' && tnHead != '/') { false - } else if (tfnHead == '/' && tnHead == '/' && tn.length == 1) { + } else if (tfnHead == '/' && tn.length == 1) { matchStrings(tfn, tn.tail) } else if (tfnHead != '+' && tfnHead != '#' && tfnHead != tnHead) { false