36 duplicated lines in: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/model.scala (23:69, 90%) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/model.scala (25:71, 85%) 33 duplicated lines in: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/scaladsl/MqttFlow.scala (29:89, 100%) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttFlow.scala (34:94, 100%) 32 duplicated lines in: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/settings.scala (29:141, 16%) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/settings.scala (35:147, 10%) 21 duplicated lines in: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala (226:258, 8%) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala (369:400, 6%) 21 duplicated lines in: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/javadsl/MqttFlow.scala (46:84, 72%) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttFlow.scala (45:83, 72%) 16 duplicated lines in: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/javadsl/MqttSource.scala (29:60, 100%) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttSource.scala (31:62, 100%) 15 duplicated lines in: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala (139:163, 6%) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala (186:209, 4%) 12 duplicated lines in: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/scaladsl/MqttSource.scala (28:55, 100%) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttSource.scala (31:58, 100%) 11 duplicated lines in: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala (267:282, 4%) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala (433:449, 3%) 11 duplicated lines in: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStageWithAck.scala (34:47, 22%) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStageWithAck.scala (35:48, 20%) 9 duplicated lines in: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala (192:203, 3%) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala (241:252, 2%) 9 duplicated lines in: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/javadsl/MqttMessageWithAck.scala (30:56, 100%) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttMessageWithAck.scala (29:55, 100%) 9 duplicated lines in: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala (126:137, 3%) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala (173:184, 2%) 8 duplicated lines in: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala (175:182, 3%) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala (222:229, 2%) 7 duplicated lines in: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala (84:90, 2%) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala (90:96, 2%) 7 duplicated lines in: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStageWithAck.scala (64:70, 14%) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStageWithAck.scala (68:74, 12%) 7 duplicated lines in: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala (84:90, 2%) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStageWithAck.scala (68:74, 12%) 7 duplicated lines in: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/javadsl/MqttFlow.scala (29:44, 24%) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttFlow.scala (28:43, 24%) 7 duplicated lines in: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala (93:102, 2%) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala (99:108, 2%) 7 duplicated lines in: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStageWithAck.scala (64:70, 14%) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala (90:96, 2%) 6 duplicated lines in: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStageWithAck.scala (85:92, 12%) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStageWithAck.scala (91:99, 11%) 6 duplicated lines in: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/javadsl/MqttSink.scala (28:41, 100%) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttSink.scala (31:44, 100%) 6 duplicated lines in: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala (58:65, 2%) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala (63:70, 1%) 6 duplicated lines in: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/model.scala (55:60, 15%) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/model.scala (66:71, 14%) 6 duplicated lines in: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/model.scala (64:69, 15%) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/model.scala (57:62, 14%)