update api text file

Author: VinayGuthal

firebase-vertexai/api.txt

@@ -127,7 +127,7 @@ package com.google.firebase.vertexai.java {
   public abstract class LiveSessionFutures {
     method public abstract com.google.common.util.concurrent.ListenableFuture<kotlin.Unit> close();
     method public static final com.google.firebase.vertexai.java.LiveSessionFutures from(com.google.firebase.vertexai.type.LiveSession session);
-    method public abstract org.reactivestreams.Publisher<com.google.firebase.vertexai.type.LiveContentResponse> receive(java.util.List<com.google.firebase.vertexai.type.ContentModality> outputModalities);
+    method public abstract org.reactivestreams.Publisher<com.google.firebase.vertexai.type.LiveContentResponse> receive();
     method public abstract com.google.common.util.concurrent.ListenableFuture<kotlin.Unit> send(com.google.firebase.vertexai.type.Content content);
     method public abstract com.google.common.util.concurrent.ListenableFuture<kotlin.Unit> send(String text);
     method public abstract com.google.common.util.concurrent.ListenableFuture<kotlin.Unit> sendFunctionResponse(java.util.List<com.google.firebase.vertexai.type.FunctionResponsePart> functionList);
@@ -626,7 +626,7 @@ package com.google.firebase.vertexai.type {
 
   public final class LiveSession {
     method public suspend Object? close(kotlin.coroutines.Continuation<? super kotlin.Unit>);
-    method public kotlinx.coroutines.flow.Flow<com.google.firebase.vertexai.type.LiveContentResponse> receive(java.util.List<com.google.firebase.vertexai.type.ContentModality> outputModalities);
+    method public kotlinx.coroutines.flow.Flow<com.google.firebase.vertexai.type.LiveContentResponse> receive();
     method public suspend Object? send(com.google.firebase.vertexai.type.Content content, kotlin.coroutines.Continuation<? super kotlin.Unit>);
     method public suspend Object? send(String text, kotlin.coroutines.Continuation<? super kotlin.Unit>);
     method public suspend Object? sendFunctionResponse(java.util.List<com.google.firebase.vertexai.type.FunctionResponsePart> functionList, kotlin.coroutines.Continuation<? super kotlin.Unit>);

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

@@ -20,7 +20,6 @@ import androidx.concurrent.futures.SuspendToFutureAdapter
 import com.google.common.util.concurrent.ListenableFuture
 import com.google.firebase.vertexai.GenerativeModel
 import com.google.firebase.vertexai.type.Content
-import com.google.firebase.vertexai.type.ContentModality
 import com.google.firebase.vertexai.type.FunctionCallPart
 import com.google.firebase.vertexai.type.FunctionResponsePart
 import com.google.firebase.vertexai.type.LiveContentResponse
@@ -91,20 +90,15 @@ public abstract class LiveSessionFutures internal constructor() {
   /**
    * Receives responses from the server for both streaming and standard requests.
    *
-   * @param outputModalities The list of output formats to receive from the server.
-   *
    * @return A [Publisher] which will emit [LiveContentResponse] as and when it receives it
    *
    * @throws [SessionAlreadyReceivingException] when the session is already receiving.
    */
-  public abstract fun receive(
-    outputModalities: List<ContentModality>
-  ): Publisher<LiveContentResponse>
+  public abstract fun receive(): Publisher<LiveContentResponse>
 
   private class FuturesImpl(private val session: LiveSession) : LiveSessionFutures() {
 
-    override fun receive(outputModalities: List<ContentModality>): Publisher<LiveContentResponse> =
-      session.receive(outputModalities).asPublisher()
+    override fun receive(): Publisher<LiveContentResponse> = session.receive().asPublisher()
 
     override fun close(): ListenableFuture<Unit> =
       SuspendToFutureAdapter.launchFuture { session.close() }

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

@@ -155,7 +155,7 @@ internal constructor(
     functionCallsHandler: ((FunctionCallPart) -> FunctionResponsePart)? = null
   ) {
     CoroutineScope(backgroundDispatcher).launch {
-      receive(listOf(ContentModality.AUDIO)).collect {
+      receive().collect {
         if (!isRecording) {
           cancel()
         }
@@ -240,13 +240,11 @@ internal constructor(
    * Receives responses from the server for both streaming and standard requests. Call
    * [stopReceiving] to stop receiving responses from the server.
    *
-   * @param outputModalities The list of output formats to receive from the server.
-   *
    * @return A [Flow] which will emit [LiveContentResponse] as and when it receives it
    *
    * @throws [SessionAlreadyReceivingException] when the session is already receiving.
    */
-  public fun receive(outputModalities: List<ContentModality>): Flow<LiveContentResponse> {
+  public fun receive(): Flow<LiveContentResponse> {
     if (startedReceiving) {
       throw SessionAlreadyReceivingException()
     }
@@ -270,15 +268,11 @@ internal constructor(
         try {
           val serverContent = Json.decodeFromString<ServerContentSetup.Internal>(receivedJson)
           val data = serverContent.serverContent.modelTurn.toPublic()
-          if (outputModalities.contains(ContentModality.AUDIO)) {
-            if (data.parts[0].asInlineDataPartOrNull()?.mimeType?.equals("audio/pcm") == true) {
-              emit(LiveContentResponse(data, LiveContentResponse.Status.NORMAL, null))
-            }
+          if (data.parts[0].asInlineDataPartOrNull()?.mimeType?.equals("audio/pcm") == true) {
+            emit(LiveContentResponse(data, LiveContentResponse.Status.NORMAL, null))
           }
-          if (outputModalities.contains(ContentModality.TEXT)) {
-            if (data.parts[0] is TextPart) {
-              emit(LiveContentResponse(data, LiveContentResponse.Status.NORMAL, null))
-            }
+          if (data.parts[0] is TextPart) {
+            emit(LiveContentResponse(data, LiveContentResponse.Status.NORMAL, null))
           }
           continue
         } catch (e: Exception) {