diff --git a/firebase-ai/app/src/main/AndroidManifest.xml b/firebase-ai/app/src/main/AndroidManifest.xml
index 0ca9215899..699c61714c 100644
--- a/firebase-ai/app/src/main/AndroidManifest.xml
+++ b/firebase-ai/app/src/main/AndroidManifest.xml
@@ -2,6 +2,10 @@
 <manifest xmlns:android="http://schemas.android.com/apk/res/android"
     xmlns:tools="http://schemas.android.com/tools">
 
+    <uses-permission android:name="android.permission.INTERNET" />
+    <uses-permission android:name="android.permission.RECORD_AUDIO" />
+    <uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE" />
+    <uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />
     <application
         android:allowBackup="true"
         android:dataExtractionRules="@xml/data_extraction_rules"
diff --git a/firebase-ai/app/src/main/java/com/google/firebase/quickstart/ai/FirebaseAISamples.kt b/firebase-ai/app/src/main/java/com/google/firebase/quickstart/ai/FirebaseAISamples.kt
index 49bd5dc181..a8da976ea8 100644
--- a/firebase-ai/app/src/main/java/com/google/firebase/quickstart/ai/FirebaseAISamples.kt
+++ b/firebase-ai/app/src/main/java/com/google/firebase/quickstart/ai/FirebaseAISamples.kt
@@ -270,6 +270,34 @@ val FIREBASE_AI_SAMPLES = listOf(
             )
         }
     ),
+    Sample(
+        title = "ForecastTalk",
+        description = "Use bidirectional streaming to get information about" +
+                " weather conditions for a specific US city on a specific date",
+        navRoute = "stream",
+        categories = listOf(Category.LIVE_API, Category.AUDIO, Category.FUNCTION_CALLING),
+        tools = listOf(
+            Tool.functionDeclarations(
+                listOf(
+                    FunctionDeclaration(
+                        "fetchWeather",
+                        "Get the weather conditions for a specific US city on a specific date.",
+                        mapOf(
+                            "city" to Schema.string("The US city of the location."),
+                            "state" to Schema.string("The US state of the location."),
+                            "date" to Schema.string(
+                                "The date for which to get the weather." +
+                                        " Date must be in the format: YYYY-MM-DD."
+                            ),
+                        ),
+                    )
+                )
+            )
+        ),
+        initialPrompt = content {
+            text("What was the weather in Boston, MA on October 17, 2024?")
+        }
+    ),
     Sample(
         title = "Weather Chat",
         description = "Use function calling to get the weather conditions" +
diff --git a/firebase-ai/app/src/main/java/com/google/firebase/quickstart/ai/MainActivity.kt b/firebase-ai/app/src/main/java/com/google/firebase/quickstart/ai/MainActivity.kt
index a1508d0d2d..54eaff6543 100644
--- a/firebase-ai/app/src/main/java/com/google/firebase/quickstart/ai/MainActivity.kt
+++ b/firebase-ai/app/src/main/java/com/google/firebase/quickstart/ai/MainActivity.kt
@@ -1,5 +1,7 @@
 package com.google.firebase.quickstart.ai
 
+import android.Manifest
+import android.content.pm.PackageManager
 import android.graphics.Bitmap
 import android.graphics.BitmapFactory
 import android.os.Bundle
@@ -19,6 +21,8 @@ import androidx.compose.runtime.mutableStateOf
 import androidx.compose.runtime.saveable.rememberSaveable
 import androidx.compose.runtime.setValue
 import androidx.compose.ui.Modifier
+import androidx.core.app.ActivityCompat
+import androidx.core.content.ContextCompat
 import androidx.navigation.NavController
 import androidx.navigation.NavDestination
 import androidx.navigation.compose.NavHost
@@ -38,6 +42,10 @@ class MainActivity : ComponentActivity() {
     @OptIn(ExperimentalMaterial3Api::class)
     override fun onCreate(savedInstanceState: Bundle?) {
         super.onCreate(savedInstanceState)
+        if(ContextCompat.checkSelfPermission(this,
+                Manifest.permission.RECORD_AUDIO) != PackageManager.PERMISSION_GRANTED) {
+            ActivityCompat.requestPermissions(this, arrayOf(Manifest.permission.RECORD_AUDIO), 1)
+        }
         enableEdgeToEdge()
         catImage = BitmapFactory.decodeResource(applicationContext.resources, R.drawable.cat)
         setContent {
diff --git a/firebase-ai/app/src/main/java/com/google/firebase/quickstart/ai/feature/live/BidiViewModel.kt b/firebase-ai/app/src/main/java/com/google/firebase/quickstart/ai/feature/live/BidiViewModel.kt
new file mode 100644
index 0000000000..a7f183704f
--- /dev/null
+++ b/firebase-ai/app/src/main/java/com/google/firebase/quickstart/ai/feature/live/BidiViewModel.kt
@@ -0,0 +1,103 @@
+package com.google.firebase.quickstart.ai.feature.media.imagen
+
+import android.Manifest
+import android.graphics.Bitmap
+import androidx.annotation.RequiresPermission
+import androidx.lifecycle.SavedStateHandle
+import androidx.lifecycle.ViewModel
+import androidx.lifecycle.viewModelScope
+import androidx.navigation.toRoute
+import com.google.firebase.Firebase
+import com.google.firebase.ai.FirebaseAI
+import com.google.firebase.ai.ImagenModel
+import com.google.firebase.ai.LiveGenerativeModel
+import com.google.firebase.ai.ai
+import com.google.firebase.ai.type.FunctionCallPart
+import com.google.firebase.ai.type.FunctionResponsePart
+import com.google.firebase.ai.type.GenerativeBackend
+import com.google.firebase.ai.type.ImagenAspectRatio
+import com.google.firebase.ai.type.ImagenImageFormat
+import com.google.firebase.ai.type.ImagenPersonFilterLevel
+import com.google.firebase.ai.type.ImagenSafetyFilterLevel
+import com.google.firebase.ai.type.ImagenSafetySettings
+import com.google.firebase.ai.type.InlineDataPart
+import com.google.firebase.ai.type.LiveServerContent
+import com.google.firebase.ai.type.LiveServerMessage
+import com.google.firebase.ai.type.LiveSession
+import com.google.firebase.ai.type.PublicPreviewAPI
+import com.google.firebase.ai.type.ResponseModality
+import com.google.firebase.ai.type.SpeechConfig
+import com.google.firebase.ai.type.TextPart
+import com.google.firebase.ai.type.Tool
+import com.google.firebase.ai.type.Voice
+import com.google.firebase.ai.type.asTextOrNull
+import com.google.firebase.ai.type.imagenGenerationConfig
+import com.google.firebase.ai.type.liveGenerationConfig
+import com.google.firebase.app
+import com.google.firebase.quickstart.ai.FIREBASE_AI_SAMPLES
+import com.google.firebase.quickstart.ai.feature.live.StreamRealtimeRoute
+import com.google.firebase.quickstart.ai.feature.text.functioncalling.WeatherRepository
+import com.google.firebase.quickstart.ai.feature.text.functioncalling.WeatherRepository.Companion.fetchWeather
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.flow.MutableStateFlow
+import kotlinx.coroutines.flow.StateFlow
+import kotlinx.coroutines.launch
+import kotlinx.coroutines.runBlocking
+import kotlinx.serialization.json.JsonObject
+import kotlinx.serialization.json.jsonPrimitive
+
+@OptIn(PublicPreviewAPI::class)
+class BidiViewModel(
+    savedStateHandle: SavedStateHandle
+) : ViewModel() {
+    private val sampleId = savedStateHandle.toRoute<StreamRealtimeRoute>().sampleId
+    private val sample = FIREBASE_AI_SAMPLES.first { it.id == sampleId }
+
+    // Firebase AI Logic
+    private var liveSession: LiveSession
+
+    init {
+        val liveGenerationConfig = liveGenerationConfig {
+            speechConfig = SpeechConfig(voice = Voice("CHARON"))
+            // Change this to ContentModality.TEXT if you want text output.
+            responseModality = ResponseModality.AUDIO
+        }
+        @OptIn(PublicPreviewAPI::class)
+        val liveModel = FirebaseAI.getInstance(Firebase.app, sample.backend).liveModel(
+            "gemini-live-2.5-flash",
+            generationConfig = liveGenerationConfig,
+            tools = sample.tools
+        )
+        runBlocking {
+            liveSession = liveModel.connect()
+        }
+    }
+
+    fun handler(fetchWeatherCall: FunctionCallPart) : FunctionResponsePart {
+        val response:JsonObject
+        fetchWeatherCall.let {
+            val city = it.args["city"]?.jsonPrimitive?.content
+            val state = it.args["state"]?.jsonPrimitive?.content
+            val date = it.args["date"]?.jsonPrimitive?.content
+            runBlocking {
+                response = if(!city.isNullOrEmpty() and !state.isNullOrEmpty() and date.isNullOrEmpty()) {
+                    fetchWeather(city!!, state!!, date!!)
+                } else {
+                    JsonObject(emptyMap())
+                }
+            }
+        }
+        return FunctionResponsePart("fetchWeather",  response, fetchWeatherCall.id)
+    }
+    @RequiresPermission(Manifest.permission.RECORD_AUDIO)
+    suspend fun startConversation() {
+      liveSession.startAudioConversation(::handler)
+    }
+
+    fun endConversation() {
+        liveSession.stopAudioConversation()
+    }
+
+
+}
diff --git a/firebase-ai/app/src/main/java/com/google/firebase/quickstart/ai/feature/live/StreamRealtimeScreen.kt b/firebase-ai/app/src/main/java/com/google/firebase/quickstart/ai/feature/live/StreamRealtimeScreen.kt
index 8cbdd721f6..f088cda23b 100644
--- a/firebase-ai/app/src/main/java/com/google/firebase/quickstart/ai/feature/live/StreamRealtimeScreen.kt
+++ b/firebase-ai/app/src/main/java/com/google/firebase/quickstart/ai/feature/live/StreamRealtimeScreen.kt
@@ -1,20 +1,146 @@
 package com.google.firebase.quickstart.ai.feature.live
 
-import androidx.compose.foundation.layout.Box
+import android.Manifest
+import androidx.annotation.RequiresPermission
+import androidx.compose.animation.animateContentSize
+import androidx.compose.foundation.layout.Arrangement
+import androidx.compose.foundation.layout.Column
+import androidx.compose.foundation.layout.Spacer
 import androidx.compose.foundation.layout.fillMaxSize
+import androidx.compose.foundation.layout.height
+import androidx.compose.foundation.layout.padding
+import androidx.compose.foundation.layout.size
+import androidx.compose.foundation.shape.CircleShape
+import androidx.compose.material.icons.Icons
+import androidx.compose.material.icons.filled.CallEnd
+import androidx.compose.material.icons.filled.Mic
+import androidx.compose.material3.Icon
+import androidx.compose.material3.IconButton
+import androidx.compose.material3.IconButtonDefaults
+import androidx.compose.material3.MaterialTheme
+import androidx.compose.material3.Surface
 import androidx.compose.material3.Text
 import androidx.compose.runtime.Composable
+import androidx.compose.ui.Alignment
 import androidx.compose.ui.Modifier
+import androidx.compose.ui.draw.clip
+import androidx.compose.ui.graphics.Color
+import androidx.compose.ui.text.font.FontWeight
+import androidx.compose.ui.unit.dp
+import androidx.compose.ui.unit.sp
+import androidx.compose.runtime.remember
+import androidx.compose.runtime.mutableStateOf
+
+import androidx.lifecycle.viewmodel.compose.viewModel
+import com.google.firebase.quickstart.ai.feature.media.imagen.BidiViewModel
+import com.google.firebase.quickstart.ai.feature.media.imagen.ImagenViewModel
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.launch
 import kotlinx.serialization.Serializable
 
 @Serializable
 class StreamRealtimeRoute(val sampleId: String)
 
+@RequiresPermission(Manifest.permission.RECORD_AUDIO)
 @Composable
-fun StreamRealtimeScreen() {
-    Box(
-        modifier = Modifier.fillMaxSize()
+fun StreamRealtimeScreen(bidiView: BidiViewModel = viewModel<BidiViewModel>()) {
+    val isConversationActive = remember { mutableStateOf(false) }
+    val backgroundColor =
+        MaterialTheme.colorScheme.background
+    Surface(
+        modifier = Modifier.fillMaxSize(),
+        color = backgroundColor
     ) {
-        Text("Coming soon")
+        Column(
+            modifier = Modifier
+                .fillMaxSize()
+                .padding(16.dp),
+            horizontalAlignment = Alignment.CenterHorizontally,
+            verticalArrangement = Arrangement.Center
+        ) {
+            // The content will animate its size when it changes
+            Column(
+                horizontalAlignment = Alignment.CenterHorizontally,
+                modifier = Modifier.animateContentSize()
+            ) {
+                if (isConversationActive.value) {
+                    // Active state UI
+                    Text(
+                        text = "Conversation Active",
+                        fontSize = 22.sp,
+                        fontWeight = FontWeight.Bold,
+                        color = MaterialTheme.colorScheme.onSurface
+                    )
+                    Spacer(modifier = Modifier.height(8.dp))
+                    Text(
+                        text = "Tap the end button to stop",
+                        fontSize = 18.sp,
+                        color = MaterialTheme.colorScheme.onSurfaceVariant
+                    )
+                } else {
+                    // Idle state UI
+                    Text(
+                        text = "Start Conversation",
+                        fontSize = 22.sp,
+                        fontWeight = FontWeight.Bold,
+                        color = MaterialTheme.colorScheme.onSurface
+                    )
+                    Spacer(modifier = Modifier.height(8.dp))
+                    Text(
+                        text = "Tap the microphone to begin",
+                        fontSize = 18.sp,
+                        color = MaterialTheme.colorScheme.onSurfaceVariant
+                    )
+                }
+            }
+
+            Spacer(modifier = Modifier.height(80.dp))
+
+            // The main button with pulsing animation
+            if (isConversationActive.value) {
+                // Button to end the conversation
+                IconButton(
+                    onClick = {
+                        bidiView.endConversation()
+                        isConversationActive.value = false },
+                    modifier = Modifier
+                        .size(90.dp)
+                        .clip(CircleShape),
+                    colors = IconButtonDefaults.iconButtonColors(
+                        containerColor = Color(0xFFE63946), // A nice red color
+                        contentColor = Color.White
+                    )
+                ) {
+                    Icon(
+                        imageVector = Icons.Default.CallEnd,
+                        contentDescription = "End Conversation",
+                        modifier = Modifier.size(48.dp)
+                    )
+                }
+            } else {
+                // Button to start the conversation
+                IconButton(
+                    onClick = {
+                        CoroutineScope(Dispatchers.IO).launch {
+                            bidiView.startConversation()
+                        }
+                        isConversationActive.value = true },
+                    modifier = Modifier
+                        .size(90.dp)
+                        .clip(CircleShape),
+                    colors = IconButtonDefaults.iconButtonColors(
+                        containerColor = MaterialTheme.colorScheme.primary,
+                        contentColor = Color.White
+                    )
+                ) {
+                    Icon(
+                        imageVector = Icons.Default.Mic,
+                        contentDescription = "Start Conversation",
+                        modifier = Modifier.size(48.dp)
+                    )
+                }
+            }
+        }
     }
 }
diff --git a/firebase-ai/app/src/main/java/com/google/firebase/quickstart/ai/ui/navigation/Sample.kt b/firebase-ai/app/src/main/java/com/google/firebase/quickstart/ai/ui/navigation/Sample.kt
index 7d8ef5117b..ad0cccbecf 100644
--- a/firebase-ai/app/src/main/java/com/google/firebase/quickstart/ai/ui/navigation/Sample.kt
+++ b/firebase-ai/app/src/main/java/com/google/firebase/quickstart/ai/ui/navigation/Sample.kt
@@ -21,6 +21,7 @@ enum class Category(
     AUDIO("Audio"),
     DOCUMENT("Document"),
     FUNCTION_CALLING("Function calling"),
+    LIVE_API("LiveAPI Streaming")
 }
 
 @OptIn(PublicPreviewAPI::class)