remove unnecesary methods

pedroSG94 · Aug 7, 2024 · 7c23f14 · 7c23f14
1 parent 251ca13
commit 7c23f14
Showing 1 changed file with 7 additions and 23 deletions.
diff --git a/library/src/main/java/com/pedro/library/generic/GenericStream.kt b/library/src/main/java/com/pedro/library/generic/GenericStream.kt
@@ -108,42 +108,26 @@ class GenericStream(
     streamClient.connecting(endPoint)
     if (endPoint.startsWith("rtmp", ignoreCase = true)) {
       connectedType = ClientType.RTMP
-      startStreamRtpRtmp(endPoint)
+      val resolution = super.getVideoResolution()
+      rtmpClient.setVideoResolution(resolution.width, resolution.height)
+      rtmpClient.setFps(super.getVideoFps())
+      rtmpClient.connect(endPoint)
     } else if (endPoint.startsWith("rtsp", ignoreCase = true)) {
       connectedType = ClientType.RTSP
-      startStreamRtpRtsp(endPoint)
+      rtspClient.connect(endPoint)
     } else if (endPoint.startsWith("srt", ignoreCase = true)) {
       connectedType = ClientType.SRT
-      startStreamRtpSrt(endPoint)
+      srtClient.connect(endPoint)
     } else if (endPoint.startsWith("udp", ignoreCase = true)) {
       connectedType = ClientType.UDP
-      startStreamRtpUdp(endPoint)
+      udpClient.connect(endPoint)
     } else {
       onMainThreadHandler {
         connectChecker.onConnectionFailed("Unsupported protocol. Only support rtmp, rtsp and srt")
       }
     }
   }
 
-  private fun startStreamRtpRtmp(endPoint: String) {
-    val resolution = super.getVideoResolution()
-    rtmpClient.setVideoResolution(resolution.width, resolution.height)
-    rtmpClient.setFps(super.getVideoFps())
-    rtmpClient.connect(endPoint)
-  }
-
-  private fun startStreamRtpRtsp(endPoint: String) {
-    rtspClient.connect(endPoint)
-  }
-
-  private fun startStreamRtpSrt(endPoint: String) {
-    srtClient.connect(endPoint)
-  }
-
-  private fun startStreamRtpUdp(endPoint: String) {
-    udpClient.connect(endPoint)
-  }
-
   override fun stopStreamImp() {
     when (connectedType) {
       ClientType.RTMP -> rtmpClient.disconnect()