- Marked channel.object.get method non-blocking using completablefuture

- Replaced ObjectsSubscription import with Subscription as per requirement

Author: sacOO7

lib/src/main/java/io/ably/lib/object/RealtimeObject.java

@@ -3,12 +3,12 @@
 import io.ably.lib.object.path.types.LiveMapPathObject;
 import io.ably.lib.object.state.ObjectStateChange;
 import io.ably.lib.object.state.ObjectStateEvent;
-import io.ably.lib.objects.ObjectsSubscription;
 import io.ably.lib.types.AblyException;
 import io.ably.lib.types.ErrorInfo;
-import org.jetbrains.annotations.Blocking;
 import org.jetbrains.annotations.NotNull;
 
+import java.util.concurrent.CompletableFuture;
+
 /**
  * The RealtimeObject interface is the entry point to the strongly-typed, path-based
  * LiveObjects API on a channel. It exposes the root of the objects graph as a
@@ -33,16 +33,17 @@ public interface RealtimeObject extends ObjectStateChange {
      * when working with multiple channels with different underlying data structures.
      *
      * <p>This operation requires the {@code OBJECT_SUBSCRIBE} channel mode. It implicitly
-     * attaches the channel if it is not already attached, and waits for the objects
-     * synchronization state to transition to {@code SYNCED} before returning.
+     * attaches the channel if it is not already attached; the returned future completes once
+     * the objects synchronization state has transitioned to {@code SYNCED}, and completes
+     * exceptionally with an {@code AblyException} if synchronization fails.
      *
      * <p>Spec: RTO23, RTO23f (typed SDKs return a {@link LiveMapPathObject})
      *
-     * @return the root {@link LiveMapPathObject} for this channel's objects graph.
+     * @return a future that completes with the root {@link LiveMapPathObject} for this
+     *         channel's objects graph.
      */
-    @Blocking
     @NotNull
-    LiveMapPathObject get();
+    CompletableFuture<LiveMapPathObject> get();
 
     /**
      * Null-Object guard for {@link RealtimeObject}, used as the value of {@code channel.object}
@@ -64,12 +65,12 @@ final class Unavailable implements RealtimeObject {
         private Unavailable() {}
 
         @Override
-        public @NotNull LiveMapPathObject get() {
+        public @NotNull CompletableFuture<LiveMapPathObject> get() {
             throw missing();
         }
 
         @Override
-        public ObjectsSubscription on(@NotNull ObjectStateEvent event, ObjectStateChange.@NotNull Listener listener) {
+        public Subscription on(@NotNull ObjectStateEvent event, ObjectStateChange.@NotNull Listener listener) {
             throw missing();
         }
 

lib/src/main/java/io/ably/lib/object/state/ObjectStateChange.java

@@ -1,6 +1,6 @@
 package io.ably.lib.object.state;
 
-import io.ably.lib.objects.ObjectsSubscription;
+import io.ably.lib.object.Subscription;
 import org.jetbrains.annotations.NonBlocking;
 import org.jetbrains.annotations.NotNull;
 
@@ -17,7 +17,7 @@ public interface ObjectStateChange {
      * @return a subscription object that can be used to unsubscribe from the event
      */
     @NonBlocking
-    ObjectsSubscription on(@NotNull ObjectStateEvent event, @NotNull ObjectStateChange.Listener listener);
+    Subscription on(@NotNull ObjectStateEvent event, @NotNull ObjectStateChange.Listener listener);
 
     /**
      * Unsubscribes the specified listener from all synchronization state events.