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 3dcba6809 refactor imports for mqttv5 (#1485)
3dcba6809 is described below
commit 3dcba680990a70fd2d2309ced253a593a24a1986
Author: PJ Fanning <[email protected]>
AuthorDate: Thu Mar 12 14:57:41 2026 +0100
refactor imports for mqttv5 (#1485)
* refactor imports for mqttv5
* scalafmt
---
.../connectors/mqttv5/impl/MqttFlowStage.scala | 49 ++++++++++++----------
.../mqttv5/impl/MqttFlowStageWithAck.scala | 19 ++++-----
.../connectors/mqttv5/javadsl/MqttFlow.scala | 7 ++--
.../mqttv5/javadsl/MqttMessageWithAck.scala | 9 ++--
.../connectors/mqttv5/javadsl/MqttSink.scala | 15 +++----
.../connectors/mqttv5/javadsl/MqttSource.scala | 13 +++---
.../connectors/mqttv5/scaladsl/MqttFlow.scala | 21 +++++-----
.../mqttv5/scaladsl/MqttMessageWithAck.scala | 9 ++--
.../connectors/mqttv5/scaladsl/MqttSink.scala | 15 +++----
.../connectors/mqttv5/scaladsl/MqttSource.scala | 15 +++----
.../src/test/java/docs/javadsl/MqttSourceTest.java | 2 -
.../test/scala/docs/scaladsl/MqttFlowSpec.scala | 23 +++++-----
.../test/scala/docs/scaladsl/MqttSinkSpec.scala | 23 +++++-----
.../test/scala/docs/scaladsl/MqttSourceSpec.scala | 29 ++++++-------
.../test/scala/docs/scaladsl/MqttSpecBase.scala | 9 ++--
15 files changed, 135 insertions(+), 123 deletions(-)
diff --git
a/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala
b/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala
index 8b50124b6..6c0bba308 100644
---
a/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala
+++
b/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala
@@ -25,30 +25,33 @@ import scala.util.Success
import scala.util.Try
import scala.util.control.NonFatal
-import org.apache.pekko.Done
-import org.apache.pekko.annotation.InternalApi
-import org.apache.pekko.stream.Shape
-import org.apache.pekko.stream._
-import org.apache.pekko.stream.connectors.mqttv5.AuthSettings
-import org.apache.pekko.stream.connectors.mqttv5.MqttConnectionSettings
-import org.apache.pekko.stream.connectors.mqttv5.MqttMessage
-import org.apache.pekko.stream.connectors.mqttv5.MqttUserProperty
-import org.apache.pekko.stream.connectors.mqttv5.MqttOfflinePersistenceSettings
-import org.apache.pekko.stream.connectors.mqttv5.MqttQoS
-import org.apache.pekko.stream.connectors.mqttv5.scaladsl.MqttMessageWithAck
-import org.apache.pekko.stream.stage._
-import org.apache.pekko.util.ByteString
-import org.eclipse.paho.mqttv5.client.DisconnectedBufferOptions
-import org.eclipse.paho.mqttv5.client.IMqttAsyncClient
-import org.eclipse.paho.mqttv5.client.IMqttToken
-import org.eclipse.paho.mqttv5.client.MqttActionListener
-import org.eclipse.paho.mqttv5.client.MqttAsyncClient
-import org.eclipse.paho.mqttv5.client.MqttCallback
-import org.eclipse.paho.mqttv5.client.MqttDisconnectResponse
+import org.apache.pekko
+import pekko.Done
+import pekko.annotation.InternalApi
+import pekko.stream.Shape
+import pekko.stream._
+import pekko.stream.connectors.mqttv5.{
+ AuthSettings,
+ MqttConnectionSettings,
+ MqttMessage,
+ MqttOfflinePersistenceSettings,
+ MqttQoS,
+ MqttUserProperty
+}
+import pekko.stream.connectors.mqttv5.scaladsl.MqttMessageWithAck
+import pekko.stream.stage._
+import pekko.util.ByteString
+import org.eclipse.paho.mqttv5.client.{
+ DisconnectedBufferOptions,
+ IMqttAsyncClient,
+ IMqttToken,
+ MqttActionListener,
+ MqttAsyncClient,
+ MqttCallback,
+ MqttDisconnectResponse
+}
import org.eclipse.paho.mqttv5.common.MqttException
-import org.eclipse.paho.mqttv5.common.packet.MqttProperties
-import org.eclipse.paho.mqttv5.common.packet.MqttReturnCode
-import org.eclipse.paho.mqttv5.common.packet.UserProperty
+import org.eclipse.paho.mqttv5.common.packet.{ MqttProperties, MqttReturnCode,
UserProperty }
import org.eclipse.paho.mqttv5.common.{ MqttMessage => PahoMqttMessage }
/**
diff --git
a/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStageWithAck.scala
b/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStageWithAck.scala
index cc94e056a..8b9c4e6cf 100644
---
a/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStageWithAck.scala
+++
b/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStageWithAck.scala
@@ -14,16 +14,15 @@
package org.apache.pekko.stream.connectors.mqttv5.impl
import scala.collection.mutable
-import scala.concurrent.Future
-import scala.concurrent.Promise
-
-import org.apache.pekko.Done
-import org.apache.pekko.annotation.InternalApi
-import org.apache.pekko.stream._
-import org.apache.pekko.stream.connectors.mqttv5.MqttConnectionSettings
-import org.apache.pekko.stream.connectors.mqttv5.MqttQoS
-import org.apache.pekko.stream.connectors.mqttv5.scaladsl.MqttMessageWithAck
-import org.apache.pekko.stream.stage._
+import scala.concurrent.{ Future, Promise }
+
+import org.apache.pekko
+import pekko.Done
+import pekko.annotation.InternalApi
+import pekko.stream._
+import pekko.stream.connectors.mqttv5.{ MqttConnectionSettings, MqttQoS }
+import pekko.stream.connectors.mqttv5.scaladsl.MqttMessageWithAck
+import pekko.stream.stage._
import org.eclipse.paho.mqttv5.client.IMqttToken
/**
diff --git
a/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttFlow.scala
b/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttFlow.scala
index 66c7843f1..ec1406579 100644
---
a/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttFlow.scala
+++
b/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttFlow.scala
@@ -15,9 +15,10 @@ package org.apache.pekko.stream.connectors.mqttv5.javadsl
import java.util.concurrent.CompletionStage
-import org.apache.pekko.Done
-import org.apache.pekko.stream.connectors.mqttv5._
-import org.apache.pekko.stream.javadsl.Flow
+import org.apache.pekko
+import pekko.Done
+import pekko.stream.connectors.mqttv5._
+import pekko.stream.javadsl.Flow
import scala.jdk.FutureConverters._
diff --git
a/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttMessageWithAck.scala
b/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttMessageWithAck.scala
index 8a649f56f..d7207176a 100644
---
a/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttMessageWithAck.scala
+++
b/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttMessageWithAck.scala
@@ -15,10 +15,11 @@ package org.apache.pekko.stream.connectors.mqttv5.javadsl
import java.util.concurrent.CompletionStage
-import org.apache.pekko.Done
-import org.apache.pekko.annotation.InternalApi
-import org.apache.pekko.stream.connectors.mqttv5.MqttMessage
-import org.apache.pekko.stream.connectors.mqttv5.scaladsl
+import org.apache.pekko
+import pekko.Done
+import pekko.annotation.InternalApi
+import pekko.stream.connectors.mqttv5.MqttMessage
+import pekko.stream.connectors.mqttv5.scaladsl
import scala.jdk.FutureConverters._
diff --git
a/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttSink.scala
b/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttSink.scala
index f849d3b58..4d494b25a 100644
---
a/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttSink.scala
+++
b/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttSink.scala
@@ -15,13 +15,14 @@ package org.apache.pekko.stream.connectors.mqttv5.javadsl
import java.util.concurrent.CompletionStage
-import org.apache.pekko.Done
-import org.apache.pekko.stream.connectors.mqttv5.MqttConnectionSettings
-import org.apache.pekko.stream.connectors.mqttv5.MqttMessage
-import org.apache.pekko.stream.connectors.mqttv5.MqttQoS
-import org.apache.pekko.stream.connectors.mqttv5.MqttSubscriptions
-import org.apache.pekko.stream.javadsl.Keep
-import org.apache.pekko.stream.javadsl.Sink
+import org.apache.pekko
+import pekko.Done
+import pekko.stream.connectors.mqttv5.MqttConnectionSettings
+import pekko.stream.connectors.mqttv5.MqttMessage
+import pekko.stream.connectors.mqttv5.MqttQoS
+import pekko.stream.connectors.mqttv5.MqttSubscriptions
+import pekko.stream.javadsl.Keep
+import pekko.stream.javadsl.Sink
/**
* Java API
diff --git
a/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttSource.scala
b/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttSource.scala
index fc0a42fc1..d92d05df2 100644
---
a/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttSource.scala
+++
b/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttSource.scala
@@ -15,12 +15,13 @@ package org.apache.pekko.stream.connectors.mqttv5.javadsl
import java.util.concurrent.CompletionStage
-import org.apache.pekko.Done
-import org.apache.pekko.stream.connectors.mqttv5.MqttConnectionSettings
-import org.apache.pekko.stream.connectors.mqttv5.MqttMessage
-import org.apache.pekko.stream.connectors.mqttv5.MqttSubscriptions
-import org.apache.pekko.stream.connectors.mqttv5.scaladsl
-import org.apache.pekko.stream.javadsl.Source
+import org.apache.pekko
+import pekko.Done
+import pekko.stream.connectors.mqttv5.MqttConnectionSettings
+import pekko.stream.connectors.mqttv5.MqttMessage
+import pekko.stream.connectors.mqttv5.MqttSubscriptions
+import pekko.stream.connectors.mqttv5.scaladsl
+import pekko.stream.javadsl.Source
import scala.jdk.FutureConverters._
diff --git
a/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttFlow.scala
b/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttFlow.scala
index e8b10e7d7..c2df937d0 100644
---
a/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttFlow.scala
+++
b/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttFlow.scala
@@ -15,16 +15,17 @@ package org.apache.pekko.stream.connectors.mqttv5.scaladsl
import scala.concurrent.Future
-import org.apache.pekko.Done
-import org.apache.pekko.stream.connectors.mqttv5.MqttConnectionSettings
-import org.apache.pekko.stream.connectors.mqttv5.MqttMessage
-import org.apache.pekko.stream.connectors.mqttv5.MqttQoS
-import org.apache.pekko.stream.connectors.mqttv5.MqttSubscriptions
-import org.apache.pekko.stream.connectors.mqttv5.impl.MqttFlowStage
-import org.apache.pekko.stream.connectors.mqttv5.impl.MqttFlowStageWithAck
-import org.apache.pekko.stream.connectors.mqttv5.javadsl
-import org.apache.pekko.stream.scaladsl.Flow
-import org.apache.pekko.stream.scaladsl.Keep
+import org.apache.pekko
+import pekko.Done
+import pekko.stream.connectors.mqttv5.MqttConnectionSettings
+import pekko.stream.connectors.mqttv5.MqttMessage
+import pekko.stream.connectors.mqttv5.MqttQoS
+import pekko.stream.connectors.mqttv5.MqttSubscriptions
+import pekko.stream.connectors.mqttv5.impl.MqttFlowStage
+import pekko.stream.connectors.mqttv5.impl.MqttFlowStageWithAck
+import pekko.stream.connectors.mqttv5.javadsl
+import pekko.stream.scaladsl.Flow
+import pekko.stream.scaladsl.Keep
/**
* Scala API
diff --git
a/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttMessageWithAck.scala
b/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttMessageWithAck.scala
index a3777eebc..4d8b08816 100644
---
a/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttMessageWithAck.scala
+++
b/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttMessageWithAck.scala
@@ -15,10 +15,11 @@ package org.apache.pekko.stream.connectors.mqttv5.scaladsl
import scala.concurrent.Future
-import org.apache.pekko.Done
-import org.apache.pekko.annotation.InternalApi
-import org.apache.pekko.stream.connectors.mqttv5.MqttMessage
-import org.apache.pekko.stream.connectors.mqttv5.javadsl
+import org.apache.pekko
+import pekko.Done
+import pekko.annotation.InternalApi
+import pekko.stream.connectors.mqttv5.MqttMessage
+import pekko.stream.connectors.mqttv5.javadsl
import scala.jdk.FutureConverters._
diff --git
a/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttSink.scala
b/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttSink.scala
index 28c158661..0cfea63cd 100644
---
a/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttSink.scala
+++
b/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttSink.scala
@@ -15,13 +15,14 @@ package org.apache.pekko.stream.connectors.mqttv5.scaladsl
import scala.concurrent.Future
-import org.apache.pekko.Done
-import org.apache.pekko.stream.connectors.mqttv5.MqttConnectionSettings
-import org.apache.pekko.stream.connectors.mqttv5.MqttMessage
-import org.apache.pekko.stream.connectors.mqttv5.MqttQoS
-import org.apache.pekko.stream.connectors.mqttv5.MqttSubscriptions
-import org.apache.pekko.stream.scaladsl.Keep
-import org.apache.pekko.stream.scaladsl.Sink
+import org.apache.pekko
+import pekko.Done
+import pekko.stream.connectors.mqttv5.MqttConnectionSettings
+import pekko.stream.connectors.mqttv5.MqttMessage
+import pekko.stream.connectors.mqttv5.MqttQoS
+import pekko.stream.connectors.mqttv5.MqttSubscriptions
+import pekko.stream.scaladsl.Keep
+import pekko.stream.scaladsl.Sink
/**
* Scala API
diff --git
a/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttSource.scala
b/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttSource.scala
index 9a4a6ee56..232491a48 100644
---
a/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttSource.scala
+++
b/mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttSource.scala
@@ -15,13 +15,14 @@ package org.apache.pekko.stream.connectors.mqttv5.scaladsl
import scala.concurrent.Future
-import org.apache.pekko.Done
-import org.apache.pekko.stream.connectors.mqttv5.MqttConnectionSettings
-import org.apache.pekko.stream.connectors.mqttv5.MqttMessage
-import org.apache.pekko.stream.connectors.mqttv5.MqttQoS
-import org.apache.pekko.stream.connectors.mqttv5.MqttSubscriptions
-import org.apache.pekko.stream.scaladsl.Keep
-import org.apache.pekko.stream.scaladsl.Source
+import org.apache.pekko
+import pekko.Done
+import pekko.stream.connectors.mqttv5.MqttConnectionSettings
+import pekko.stream.connectors.mqttv5.MqttMessage
+import pekko.stream.connectors.mqttv5.MqttQoS
+import pekko.stream.connectors.mqttv5.MqttSubscriptions
+import pekko.stream.scaladsl.Keep
+import pekko.stream.scaladsl.Source
/**
* Scala API
diff --git a/mqttv5/src/test/java/docs/javadsl/MqttSourceTest.java
b/mqttv5/src/test/java/docs/javadsl/MqttSourceTest.java
index e44732009..f22bed43a 100644
--- a/mqttv5/src/test/java/docs/javadsl/MqttSourceTest.java
+++ b/mqttv5/src/test/java/docs/javadsl/MqttSourceTest.java
@@ -51,8 +51,6 @@ import java.util.stream.Collectors;
import java.util.stream.IntStream;
import java.util.stream.Stream;
-import scala.jdk.javaapi.CollectionConverters;
-
import static org.hamcrest.CoreMatchers.containsString;
import static org.hamcrest.CoreMatchers.is;
import static org.hamcrest.MatcherAssert.assertThat;
diff --git a/mqttv5/src/test/scala/docs/scaladsl/MqttFlowSpec.scala
b/mqttv5/src/test/scala/docs/scaladsl/MqttFlowSpec.scala
index fde27f43b..e94b9071e 100644
--- a/mqttv5/src/test/scala/docs/scaladsl/MqttFlowSpec.scala
+++ b/mqttv5/src/test/scala/docs/scaladsl/MqttFlowSpec.scala
@@ -16,17 +16,18 @@ package docs.scaladsl
import scala.concurrent.Future
import scala.concurrent.Promise
-import org.apache.pekko.Done
-import org.apache.pekko.stream.connectors.mqttv5.MqttMessage
-import org.apache.pekko.stream.connectors.mqttv5.MqttQoS
-import org.apache.pekko.stream.connectors.mqttv5.MqttSubscriptions
-import org.apache.pekko.stream.connectors.mqttv5.scaladsl.MqttFlow
-import org.apache.pekko.stream.connectors.mqttv5.scaladsl.MqttMessageWithAck
-import org.apache.pekko.stream.scaladsl.Flow
-import org.apache.pekko.stream.scaladsl.Keep
-import org.apache.pekko.stream.scaladsl.Sink
-import org.apache.pekko.stream.scaladsl.Source
-import org.apache.pekko.util.ByteString
+import org.apache.pekko
+import pekko.Done
+import pekko.stream.connectors.mqttv5.MqttMessage
+import pekko.stream.connectors.mqttv5.MqttQoS
+import pekko.stream.connectors.mqttv5.MqttSubscriptions
+import pekko.stream.connectors.mqttv5.scaladsl.MqttFlow
+import pekko.stream.connectors.mqttv5.scaladsl.MqttMessageWithAck
+import pekko.stream.scaladsl.Flow
+import pekko.stream.scaladsl.Keep
+import pekko.stream.scaladsl.Sink
+import pekko.stream.scaladsl.Source
+import pekko.util.ByteString
class MqttFlowSpec extends MqttSpecBase("MqttFlowSpec") {
diff --git a/mqttv5/src/test/scala/docs/scaladsl/MqttSinkSpec.scala
b/mqttv5/src/test/scala/docs/scaladsl/MqttSinkSpec.scala
index 03b287eeb..4cf6abe6c 100644
--- a/mqttv5/src/test/scala/docs/scaladsl/MqttSinkSpec.scala
+++ b/mqttv5/src/test/scala/docs/scaladsl/MqttSinkSpec.scala
@@ -16,17 +16,18 @@ package docs.scaladsl
import scala.concurrent.Await
import scala.concurrent.duration._
-import org.apache.pekko.Done
-import org.apache.pekko.stream.connectors.mqttv5
-import org.apache.pekko.stream.connectors.mqttv5.MqttMessage
-import org.apache.pekko.stream.connectors.mqttv5.MqttQoS
-import org.apache.pekko.stream.connectors.mqttv5.MqttSubscriptions
-import org.apache.pekko.stream.connectors.mqttv5.scaladsl.MqttSink
-import org.apache.pekko.stream.connectors.mqttv5.scaladsl.MqttSource
-import org.apache.pekko.stream.scaladsl.Keep
-import org.apache.pekko.stream.scaladsl.Sink
-import org.apache.pekko.stream.scaladsl.Source
-import org.apache.pekko.util.ByteString
+import org.apache.pekko
+import pekko.Done
+import pekko.stream.connectors.mqttv5
+import pekko.stream.connectors.mqttv5.MqttMessage
+import pekko.stream.connectors.mqttv5.MqttQoS
+import pekko.stream.connectors.mqttv5.MqttSubscriptions
+import pekko.stream.connectors.mqttv5.scaladsl.MqttSink
+import pekko.stream.connectors.mqttv5.scaladsl.MqttSource
+import pekko.stream.scaladsl.Keep
+import pekko.stream.scaladsl.Sink
+import pekko.stream.scaladsl.Source
+import pekko.util.ByteString
import org.eclipse.paho.mqttv5.common.MqttException
class MqttSinkSpec extends MqttSpecBase("MqttSinkSpec") {
diff --git a/mqttv5/src/test/scala/docs/scaladsl/MqttSourceSpec.scala
b/mqttv5/src/test/scala/docs/scaladsl/MqttSourceSpec.scala
index 7b875d171..5fe9ab64a 100644
--- a/mqttv5/src/test/scala/docs/scaladsl/MqttSourceSpec.scala
+++ b/mqttv5/src/test/scala/docs/scaladsl/MqttSourceSpec.scala
@@ -21,20 +21,21 @@ import scala.concurrent.Future
import scala.concurrent.Promise
import scala.concurrent.duration._
-import org.apache.pekko.Done
-import org.apache.pekko.NotUsed
-import org.apache.pekko.stream._
-import org.apache.pekko.stream.connectors.mqttv5.MqttConnectionSettings
-import org.apache.pekko.stream.connectors.mqttv5.MqttMessage
-import org.apache.pekko.stream.connectors.mqttv5.MqttQoS
-import org.apache.pekko.stream.connectors.mqttv5.MqttSubscriptions
-import org.apache.pekko.stream.connectors.mqttv5.MqttUserProperty
-import org.apache.pekko.stream.connectors.mqttv5.scaladsl.MqttMessageWithAck
-import org.apache.pekko.stream.connectors.mqttv5.scaladsl.MqttSink
-import org.apache.pekko.stream.connectors.mqttv5.scaladsl.MqttSource
-import org.apache.pekko.stream.scaladsl._
-import org.apache.pekko.stream.testkit.scaladsl.TestSink
-import org.apache.pekko.util.ByteString
+import org.apache.pekko
+import pekko.Done
+import pekko.NotUsed
+import pekko.stream._
+import pekko.stream.connectors.mqttv5.MqttConnectionSettings
+import pekko.stream.connectors.mqttv5.MqttMessage
+import pekko.stream.connectors.mqttv5.MqttQoS
+import pekko.stream.connectors.mqttv5.MqttSubscriptions
+import pekko.stream.connectors.mqttv5.MqttUserProperty
+import pekko.stream.connectors.mqttv5.scaladsl.MqttMessageWithAck
+import pekko.stream.connectors.mqttv5.scaladsl.MqttSink
+import pekko.stream.connectors.mqttv5.scaladsl.MqttSource
+import pekko.stream.scaladsl._
+import pekko.stream.testkit.scaladsl.TestSink
+import pekko.util.ByteString
import org.eclipse.paho.mqttv5.client.persist.MemoryPersistence
import org.eclipse.paho.mqttv5.common.MqttException
import org.slf4j.LoggerFactory
diff --git a/mqttv5/src/test/scala/docs/scaladsl/MqttSpecBase.scala
b/mqttv5/src/test/scala/docs/scaladsl/MqttSpecBase.scala
index c031488be..c8b10cce5 100644
--- a/mqttv5/src/test/scala/docs/scaladsl/MqttSpecBase.scala
+++ b/mqttv5/src/test/scala/docs/scaladsl/MqttSpecBase.scala
@@ -15,10 +15,11 @@ package docs.scaladsl
import scala.concurrent.duration._
-import org.apache.pekko.actor.ActorSystem
-import org.apache.pekko.stream.connectors.mqttv5.MqttConnectionSettings
-import org.apache.pekko.stream.connectors.testkit.scaladsl.LogCapturing
-import org.apache.pekko.testkit.TestKit
+import org.apache.pekko
+import pekko.actor.ActorSystem
+import pekko.stream.connectors.mqttv5.MqttConnectionSettings
+import pekko.stream.connectors.testkit.scaladsl.LogCapturing
+import pekko.testkit.TestKit
import org.eclipse.paho.mqttv5.client.persist.MemoryPersistence
import org.scalatest.BeforeAndAfterAll
import org.scalatest.concurrent.Eventually
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
