[Android][Compose]1.fix pip crash;2.fix rhythmplayer mute bug;3.fix r…

…tmp push bug.

Android/APIExample-Compose/app/src/main/java/io/agora/api/example/compose/samples/PictureInPicture.kt

@@ -328,7 +328,7 @@ private fun PictureInPicture() {
 }
 
 
-private class PictureInPictureActivity : ComponentActivity() {
+class PictureInPictureActivity : ComponentActivity() {
 
     override fun onCreate(savedInstanceState: Bundle?) {
         super.onCreate(savedInstanceState)

Android/APIExample-Compose/app/src/main/java/io/agora/api/example/compose/samples/RTMPStreaming.kt

@@ -1,5 +1,7 @@
 package io.agora.api.example.compose.samples
 
+import android.os.Handler
+import android.util.Log
 import android.widget.Toast
 import androidx.activity.compose.rememberLauncherForActivityResult
 import androidx.activity.result.contract.ActivityResultContracts
@@ -33,7 +35,6 @@ import io.agora.rtc2.Constants
 import io.agora.rtc2.IRtcEngineEventHandler
 import io.agora.rtc2.RtcEngine
 import io.agora.rtc2.RtcEngineConfig
-import io.agora.rtc2.SimulcastStreamConfig
 import io.agora.rtc2.live.LiveTranscoding
 import io.agora.rtc2.video.VideoCanvas
 import io.agora.rtc2.video.VideoEncoderConfiguration
@@ -43,6 +44,7 @@ fun RTMPStreaming() {
     val context = LocalContext.current
     val lifecycleOwner = LocalLifecycleOwner.current
     val keyboard = LocalSoftwareKeyboardController.current
+    val mainHandler = remember { Handler(context.mainLooper) }
     var isJoined by rememberSaveable { mutableStateOf(false) }
     var localLarge by rememberSaveable { mutableStateOf(true) }
     var channelName by rememberSaveable { mutableStateOf("") }
@@ -149,6 +151,25 @@ fun RTMPStreaming() {
                     super.onClientRoleChanged(oldRole, newRole, newRoleOptions)
                     clientRole = newRole
                 }
+
+                override fun onRtmpStreamingStateChanged(url: String?, state: Int, reason: Int) {
+                    super.onRtmpStreamingStateChanged(url, state, reason)
+                    Log.d("RTMPStreaming", "onRtmpStreamingStateChanged: $url, $state, $reason")
+                    if (state == Constants.RTMP_STREAM_PUBLISH_STATE_IDLE) {
+                        pushing = false
+                    } else if (state == Constants.RTMP_STREAM_PUBLISH_STATE_RUNNING) {
+                        pushing = true
+                    }
+                }
+
+                override fun onRtmpStreamingEvent(url: String?, event: Int) {
+                    super.onRtmpStreamingEvent(url, event)
+                    if (event == Constants.RTMP_STREAMING_EVENT_URL_ALREADY_IN_USE) {
+                        mainHandler.post {
+                            Toast.makeText(context, "URL already in use: $url", Toast.LENGTH_LONG).show()
+                        }
+                    }
+                }
             }
         }).apply {
             engine = this
@@ -161,14 +182,6 @@ fun RTMPStreaming() {
                 )
             )
             enableVideo()
-            setDualStreamMode(
-                Constants.SimulcastStreamMode.ENABLE_SIMULCAST_STREAM,
-                SimulcastStreamConfig(
-                    VideoEncoderConfiguration.VideoDimensions(
-                        100, 100
-                    ), 100, 15
-                )
-            )
         }
     }
     DisposableEffect(lifecycleOwner) {
@@ -224,7 +237,6 @@ fun RTMPStreaming() {
             pushing = !pushing
 
             if (pushing) {
-                rtcEngine?.stopRtmpStream(url)
                 if (transcoding) {
                     rtcEngine?.startRtmpStreamWithTranscoding(url,
                         getRtmpStreamTranscoding(localUid, remoteUid)
@@ -337,25 +349,25 @@ private fun getRtmpStreamTranscoding(
     remoteUid: Int
 ): LiveTranscoding {
     return LiveTranscoding().apply {
-        width = 640
-        height = 360
+        width = 360
+        height = 640
         videoBitrate = 400
         videoFramerate = 15
         addUser(LiveTranscoding.TranscodingUser().apply {
             uid = localUid
             x = 0
             y = 0
-            width = 640
-            height = 180
+            width = 360
+            height = 320
             zOrder = 1
         })
         if (remoteUid != 0) {
             addUser(LiveTranscoding.TranscodingUser().apply {
                 uid = remoteUid
                 x = 0
-                y = 180
-                width = 640
-                height = 180
+                y = 320
+                width = 360
+                height = 320
                 zOrder = 2
             })
         }

Android/APIExample-Compose/app/src/main/java/io/agora/api/example/compose/samples/RhythmPlayer.kt

@@ -104,8 +104,8 @@ fun RhythmPlayer() {
             mediaOptions.clientRoleType = Constants.CLIENT_ROLE_BROADCASTER
             mediaOptions.autoSubscribeAudio = true
             mediaOptions.autoSubscribeVideo = true
-            mediaOptions.publishRhythmPlayerTrack = true
-            mediaOptions.publishMicrophoneTrack = false
+            mediaOptions.publishRhythmPlayerTrack = isPlaying
+            mediaOptions.publishMicrophoneTrack = true
             mediaOptions.publishCameraTrack = false
             TokenUtils.gen(channelName, 0) {
                 rtcEngine.joinChannel(it, channelName, 0, mediaOptions)
@@ -153,6 +153,11 @@ private fun RhythmPlayerView(
                         .padding(8.dp, 0.dp),
                     onClick = {
                         rtcEngine?.startRhythmPlayer(URL_UPBEAT, URL_DOWNBEAT, config)
+                        if(isJoined){
+                            rtcEngine?.updateChannelMediaOptions(ChannelMediaOptions().apply {
+                                publishRhythmPlayerTrack = true
+                            })
+                        }
                     }
                 ) {
                     Text(text = stringResource(id = R.string.play))
@@ -163,6 +168,11 @@ private fun RhythmPlayerView(
                         .padding(8.dp, 0.dp),
                     onClick = {
                         rtcEngine?.stopRhythmPlayer()
+                        if(isJoined){
+                            rtcEngine?.updateChannelMediaOptions(ChannelMediaOptions().apply {
+                                publishRhythmPlayerTrack = false
+                            })
+                        }
                         onPlayStopClick()
                     }
                 ) {