update code

Author: VinayGuthal

firebase-ai/api.txt

@@ -142,6 +142,8 @@ package com.google.firebase.ai.java {
   @com.google.firebase.ai.type.PublicPreviewAPI public abstract class LiveSessionFutures {
     method public abstract com.google.common.util.concurrent.ListenableFuture<kotlin.Unit> close();
     method public static final com.google.firebase.ai.java.LiveSessionFutures from(com.google.firebase.ai.type.LiveSession session);
+    method public abstract boolean isAudioConversationActive();
+    method public abstract boolean isClosed();
     method public abstract org.reactivestreams.Publisher<com.google.firebase.ai.type.LiveServerMessage> receive();
     method public abstract com.google.common.util.concurrent.ListenableFuture<kotlin.Unit> send(com.google.firebase.ai.type.Content content);
     method public abstract com.google.common.util.concurrent.ListenableFuture<kotlin.Unit> send(String text);
@@ -879,6 +881,8 @@ package com.google.firebase.ai.type {
 
   @com.google.firebase.ai.type.PublicPreviewAPI public final class LiveSession {
     method public suspend Object? close(kotlin.coroutines.Continuation<? super kotlin.Unit>);
+    method public boolean isAudioConversationActive();
+    method public boolean isClosed();
     method public kotlinx.coroutines.flow.Flow<com.google.firebase.ai.type.LiveServerMessage> receive();
     method public suspend Object? send(com.google.firebase.ai.type.Content content, kotlin.coroutines.Continuation<? super kotlin.Unit>);
     method public suspend Object? send(String text, kotlin.coroutines.Continuation<? super kotlin.Unit>);
@@ -918,6 +922,10 @@ package com.google.firebase.ai.type {
     method public static String? asTextOrNull(com.google.firebase.ai.type.Part);
   }
 
+  public final class PermissionMissingException extends com.google.firebase.ai.type.FirebaseAIException {
+    ctor public PermissionMissingException(String message, Throwable? cause = null);
+  }
+
   public final class PromptBlockedException extends com.google.firebase.ai.type.FirebaseAIException {
     method public com.google.firebase.ai.type.GenerateContentResponse? getResponse();
     property public final com.google.firebase.ai.type.GenerateContentResponse? response;

firebase-ai/src/main/kotlin/com/google/firebase/ai/java/LiveSessionFutures.kt

@@ -29,7 +29,6 @@ import com.google.firebase.ai.type.MediaData
 import com.google.firebase.ai.type.PublicPreviewAPI
 import com.google.firebase.ai.type.SessionAlreadyReceivingException
 import io.ktor.websocket.close
-import kotlinx.coroutines.isActive
 import kotlinx.coroutines.reactive.asPublisher
 import org.reactivestreams.Publisher
 
@@ -53,10 +52,10 @@ public abstract class LiveSessionFutures internal constructor() {
   ): ListenableFuture<Unit>
 
   /** Indicates whether the underlying websocket connection is active. */
-  public abstract fun isActive(): ListenableFuture<Boolean>
+  public abstract fun isClosed(): Boolean
 
   /** Indicates whether an audio conversation is being used for this session object. */
-  public abstract fun isAudioConversationActive(): ListenableFuture<Boolean>
+  public abstract fun isAudioConversationActive(): Boolean
 
   /**
    * Starts an audio conversation with the model, which can only be stopped using
@@ -176,10 +175,9 @@ public abstract class LiveSessionFutures internal constructor() {
     override fun startAudioConversation() =
       SuspendToFutureAdapter.launchFuture { session.startAudioConversation() }
 
-    override fun isActive() = SuspendToFutureAdapter.launchFuture { session.isActive() }
+    override fun isClosed() = session.isClosed()
 
-    override fun isAudioConversationActive() =
-      SuspendToFutureAdapter.launchFuture { session.isAudioConversationActive() }
+    override fun isAudioConversationActive() = session.isAudioConversationActive()
 
     override fun stopAudioConversation() =
       SuspendToFutureAdapter.launchFuture { session.stopAudioConversation() }

firebase-ai/src/main/kotlin/com/google/firebase/ai/type/LiveSession.kt

@@ -144,7 +144,7 @@ internal constructor(
   }
 
   /** Indicates whether the underlying websocket connection is active. */
-  public fun isActive(): Boolean = session.isActive
+  public fun isClosed(): Boolean = !(session.isActive && !session.incoming.tryReceive().isClosed)
 
   /** Indicates whether an audio conversation is being used for this session object. */
   public fun isAudioConversationActive(): Boolean = (audioHelper != null)