Move CompletableFlow from rx.internal -> internal.rx

hivemq · Nov 19, 2023 · 0c9fad3 · 0c9fad3
1 parent bbba2cf
commit 0c9fad3
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.rx.internal.CompletableFlow;
+import com.hivemq.mqtt.client2.internal.rx.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
@@ -23,14 +23,14 @@
 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;
 import com.hivemq.mqtt.client2.mqtt5.message.auth.Mqtt5Auth;
 import com.hivemq.mqtt.client2.mqtt5.message.auth.Mqtt5AuthBuilder;
 import com.hivemq.mqtt.client2.mqtt5.message.disconnect.Mqtt5Disconnect;
 import com.hivemq.mqtt.client2.mqtt5.message.disconnect.Mqtt5DisconnectReasonCode;
-import com.hivemq.mqtt.client2.rx.internal.CompletableFlow;
 import io.netty.channel.ChannelHandlerContext;
 import org.jetbrains.annotations.NotNull;
 import org.jetbrains.annotations.Nullable;

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
@@ -20,7 +20,7 @@
 import com.hivemq.mqtt.client2.internal.MqttClientConnectionConfig;
 import com.hivemq.mqtt.client2.internal.exceptions.MqttClientStateExceptions;
 import com.hivemq.mqtt.client2.internal.message.disconnect.MqttDisconnect;
-import com.hivemq.mqtt.client2.rx.internal.CompletableFlow;
+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
@@ -17,10 +17,10 @@
 package com.hivemq.mqtt.client2.internal.handler.disconnect;
 
 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;
-import com.hivemq.mqtt.client2.rx.internal.CompletableFlow;
 import org.jetbrains.annotations.NotNull;
 import org.jetbrains.annotations.Nullable;
 

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
@@ -32,12 +32,12 @@
 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;
 import com.hivemq.mqtt.client2.mqtt5.exceptions.Mqtt5DisconnectException;
 import com.hivemq.mqtt.client2.mqtt5.message.disconnect.Mqtt5DisconnectReasonCode;
-import com.hivemq.mqtt.client2.rx.internal.CompletableFlow;
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.EventLoop;

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