Move CompletableFlow from internal.rx -> internal.handler.util

hivemq · Nov 20, 2023 · 6c63e36 · 6c63e36
1 parent b937b4d
commit 6c63e36
Show file tree

Hide file tree

Showing 6 changed files with 6 additions and 6 deletions.
diff --git a/src/main/java/com/hivemq/mqtt/client2/internal/handler/auth/MqttReAuthCompletable.java b/src/main/java/com/hivemq/mqtt/client2/internal/handler/auth/MqttReAuthCompletable.java
@@ -19,7 +19,7 @@
 import com.hivemq.mqtt.client2.internal.MqttClientConfig;
 import com.hivemq.mqtt.client2.internal.MqttClientConnectionConfig;
 import com.hivemq.mqtt.client2.internal.exceptions.MqttClientStateExceptions;
-import com.hivemq.mqtt.client2.internal.rx.CompletableFlow;
+import com.hivemq.mqtt.client2.internal.handler.util.CompletableFlow;
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelHandler;
 import io.reactivex.rxjava3.core.Completable;

diff --git a/src/main/java/com/hivemq/mqtt/client2/internal/handler/auth/MqttReAuthHandler.java b/src/main/java/com/hivemq/mqtt/client2/internal/handler/auth/MqttReAuthHandler.java
@@ -19,11 +19,11 @@
 import com.hivemq.mqtt.client2.internal.exceptions.MqttClientStateExceptions;
 import com.hivemq.mqtt.client2.internal.handler.disconnect.MqttDisconnectEvent;
 import com.hivemq.mqtt.client2.internal.handler.disconnect.MqttDisconnectUtil;
+import com.hivemq.mqtt.client2.internal.handler.util.CompletableFlow;
 import com.hivemq.mqtt.client2.internal.ioc.ConnectionScope;
 import com.hivemq.mqtt.client2.internal.message.auth.MqttAuth;
 import com.hivemq.mqtt.client2.internal.message.auth.MqttAuthBuilder;
 import com.hivemq.mqtt.client2.internal.message.disconnect.MqttDisconnect;
-import com.hivemq.mqtt.client2.internal.rx.CompletableFlow;
 import com.hivemq.mqtt.client2.mqtt5.Mqtt5ClientConfig;
 import com.hivemq.mqtt.client2.mqtt5.auth.Mqtt5EnhancedAuthMechanism;
 import com.hivemq.mqtt.client2.mqtt5.exceptions.Mqtt5AuthException;

diff --git a/...n/java/com/hivemq/mqtt/client2/internal/handler/disconnect/MqttDisconnectCompletable.java b/...n/java/com/hivemq/mqtt/client2/internal/handler/disconnect/MqttDisconnectCompletable.java
@@ -19,8 +19,8 @@
 import com.hivemq.mqtt.client2.internal.MqttClientConfig;
 import com.hivemq.mqtt.client2.internal.MqttClientConnectionConfig;
 import com.hivemq.mqtt.client2.internal.exceptions.MqttClientStateExceptions;
+import com.hivemq.mqtt.client2.internal.handler.util.CompletableFlow;
 import com.hivemq.mqtt.client2.internal.message.disconnect.MqttDisconnect;
-import com.hivemq.mqtt.client2.internal.rx.CompletableFlow;
 import io.netty.channel.Channel;
 import io.reactivex.rxjava3.core.Completable;
 import io.reactivex.rxjava3.core.CompletableObserver;

diff --git a/src/main/java/com/hivemq/mqtt/client2/internal/handler/disconnect/MqttDisconnectEvent.java b/src/main/java/com/hivemq/mqtt/client2/internal/handler/disconnect/MqttDisconnectEvent.java
@@ -16,8 +16,8 @@
 
 package com.hivemq.mqtt.client2.internal.handler.disconnect;
 
+import com.hivemq.mqtt.client2.internal.handler.util.CompletableFlow;
 import com.hivemq.mqtt.client2.internal.message.disconnect.MqttDisconnect;
-import com.hivemq.mqtt.client2.internal.rx.CompletableFlow;
 import com.hivemq.mqtt.client2.lifecycle.MqttDisconnectSource;
 import com.hivemq.mqtt.client2.mqtt5.exceptions.Mqtt5DisconnectException;
 import com.hivemq.mqtt.client2.mqtt5.message.disconnect.Mqtt5Disconnect;

diff --git a/src/main/java/com/hivemq/mqtt/client2/internal/handler/disconnect/MqttDisconnectHandler.java b/src/main/java/com/hivemq/mqtt/client2/internal/handler/disconnect/MqttDisconnectHandler.java
@@ -25,14 +25,14 @@
 import com.hivemq.mqtt.client2.internal.handler.MqttConnectionAwareHandler;
 import com.hivemq.mqtt.client2.internal.handler.MqttSession;
 import com.hivemq.mqtt.client2.internal.handler.connect.MqttConnAckSingle;
+import com.hivemq.mqtt.client2.internal.handler.util.CompletableFlow;
 import com.hivemq.mqtt.client2.internal.ioc.ConnectionScope;
 import com.hivemq.mqtt.client2.internal.logging.InternalLogger;
 import com.hivemq.mqtt.client2.internal.logging.InternalLoggerFactory;
 import com.hivemq.mqtt.client2.internal.message.connect.MqttConnAck;
 import com.hivemq.mqtt.client2.internal.message.connect.MqttConnect;
 import com.hivemq.mqtt.client2.internal.message.connect.MqttConnectRestrictions;
 import com.hivemq.mqtt.client2.internal.message.disconnect.MqttDisconnect;
-import com.hivemq.mqtt.client2.internal.rx.CompletableFlow;
 import com.hivemq.mqtt.client2.lifecycle.MqttDisconnectSource;
 import com.hivemq.mqtt.client2.mqtt5.auth.Mqtt5EnhancedAuthMechanism;
 import com.hivemq.mqtt.client2.mqtt5.exceptions.Mqtt5ConnAckException;

diff --git a/.../client2/internal/rx/CompletableFlow.java → ...nternal/handler/util/CompletableFlow.java b/.../client2/internal/rx/CompletableFlow.java → ...nternal/handler/util/CompletableFlow.java
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package com.hivemq.mqtt.client2.internal.rx;
+package com.hivemq.mqtt.client2.internal.handler.util;
 
 import io.reactivex.rxjava3.core.CompletableObserver;
 import io.reactivex.rxjava3.disposables.Disposable;