add setBitrateExponentialFactor and getBitrateExponentialFactor

app/src/main/java/com/pedro/streamer/rotation/CameraFragment.kt

@@ -75,6 +75,7 @@ class CameraFragment: Fragment(), ConnectChecker {
   val genericStream: GenericStream by lazy {
     GenericStream(requireContext(), this).apply {
       getGlInterface().autoHandleOrientation = true
+      getStreamClient().setBitrateExponentialFactor(0.5f)
     }
   }
   private lateinit var surfaceView: SurfaceView
@@ -100,7 +101,6 @@ class CameraFragment: Fragment(), ConnectChecker {
     val etUrl = view.findViewById<EditText>(R.id.et_rtp_url)
 
     txtBitrate = view.findViewById(R.id.txt_bitrate)
-
     surfaceView = view.findViewById(R.id.surfaceView)
     (activity as? RotationActivity)?.let {
       surfaceView.setOnTouchListener(it)
@@ -207,7 +207,7 @@ class CameraFragment: Fragment(), ConnectChecker {
   }
 
   override fun onNewBitrate(bitrate: Long) {
-    txtBitrate.text = String.format("%.1f mb/s", bitrate / 1000f / 1000f)
+    txtBitrate.text = String.format(Locale.getDefault(), "%.1f mb/s", bitrate / 1000_000f)
   }
 
   override fun onDisconnect() {

common/src/main/java/com/pedro/common/BitrateManager.kt

@@ -27,7 +27,7 @@ open class BitrateManager(private val bitrateChecker: BitrateChecker) {
 
   private var bitrate = 0L
   private var bitrateOld = 0L
-  private val exponentialFactor: Float = 0.5f
+  var exponentialFactor: Float = 1f
   private var timeStamp = TimeUtils.getCurrentTimeMillis()
 
   suspend fun calculateBitrate(size: Long) {
@@ -47,5 +47,4 @@ open class BitrateManager(private val bitrateChecker: BitrateChecker) {
     bitrate = 0
     bitrateOld = 0
   }
-
 }

library/src/main/java/com/pedro/library/util/streamclient/GenericStreamClient.kt

@@ -203,4 +203,20 @@ class GenericStreamClient(
         udpClient
       } else null
   }
+
+  /**
+   * @param factor values from 0.1f to 1f
+   * Set an exponential factor to the bitrate calculation to avoid bitrate spikes
+   */
+  override fun setBitrateExponentialFactor(factor: Float) {
+    rtmpClient.setBitrateExponentialFactor(factor)
+    rtspClient.setBitrateExponentialFactor(factor)
+    srtClient.setBitrateExponentialFactor(factor)
+    udpClient.setBitrateExponentialFactor(factor)
+  }
+
+  /**
+   * Get the exponential factor used to calculate the bitrate. Default 1f
+   */
+  override fun getBitrateExponentialFactor() = connectedStreamClient?.getBitrateExponentialFactor() ?: 1f
 }

library/src/main/java/com/pedro/library/util/streamclient/RtmpStreamClient.kt

@@ -139,4 +139,17 @@ class RtmpStreamClient(
   override fun setOnlyVideo(onlyVideo: Boolean) {
     rtmpClient.setOnlyVideo(onlyVideo)
   }
+
+  /**
+   * @param factor values from 0.1f to 1f
+   * Set an exponential factor to the bitrate calculation to avoid bitrate spikes
+   */
+  override fun setBitrateExponentialFactor(factor: Float) {
+    rtmpClient.setBitrateExponentialFactor(factor)
+  }
+
+  /**
+   * Get the exponential factor used to calculate the bitrate. Default 1f
+   */
+  override fun getBitrateExponentialFactor() = rtmpClient.getBitrateExponentialFactor()
 }

library/src/main/java/com/pedro/library/util/streamclient/RtspStreamClient.kt

@@ -114,4 +114,17 @@ class RtspStreamClient(
   override fun setOnlyVideo(onlyVideo: Boolean) {
     rtspClient.setOnlyVideo(onlyVideo)
   }
+
+  /**
+   * @param factor values from 0.1f to 1f
+   * Set an exponential factor to the bitrate calculation to avoid bitrate spikes
+   */
+  override fun setBitrateExponentialFactor(factor: Float) {
+    rtspClient.setBitrateExponentialFactor(factor)
+  }
+
+  /**
+   * Get the exponential factor used to calculate the bitrate. Default 1f
+   */
+  override fun getBitrateExponentialFactor() = rtspClient.getBitrateExponentialFactor()
 }

library/src/main/java/com/pedro/library/util/streamclient/SrtStreamClient.kt

@@ -104,4 +104,17 @@ class SrtStreamClient(
   override fun setOnlyVideo(onlyVideo: Boolean) {
     srtClient.setOnlyVideo(onlyVideo)
   }
+
+  /**
+   * @param factor values from 0.1f to 1f
+   * Set an exponential factor to the bitrate calculation to avoid bitrate spikes
+   */
+  override fun setBitrateExponentialFactor(factor: Float) {
+    srtClient.setBitrateExponentialFactor(factor)
+  }
+
+  /**
+   * Get the exponential factor used to calculate the bitrate. Default 1f
+   */
+  override fun getBitrateExponentialFactor() = srtClient.getBitrateExponentialFactor()
 }

library/src/main/java/com/pedro/library/util/streamclient/StreamBaseClient.kt

@@ -59,4 +59,15 @@ abstract class StreamBaseClient {
   abstract fun resetDroppedVideoFrames()
   abstract fun setOnlyAudio(onlyAudio: Boolean)
   abstract fun setOnlyVideo(onlyVideo: Boolean)
+
+  /**
+   * @param factor values from 0.1f to 1f
+   * Set an exponential factor to the bitrate calculation to avoid bitrate spikes
+   */
+  abstract fun setBitrateExponentialFactor(factor: Float)
+
+  /**
+   * Get the exponential factor used to calculate the bitrate. Default 1f
+   */
+  abstract fun getBitrateExponentialFactor(): Float
 }

library/src/main/java/com/pedro/library/util/streamclient/UdpStreamClient.kt

@@ -97,4 +97,17 @@ class UdpStreamClient(
   override fun setOnlyVideo(onlyVideo: Boolean) {
     udpClient.setOnlyVideo(onlyVideo)
   }
+
+  /**
+   * @param factor values from 0.1f to 1f
+   * Set an exponential factor to the bitrate calculation to avoid bitrate spikes
+   */
+  override fun setBitrateExponentialFactor(factor: Float) {
+    udpClient.setBitrateExponentialFactor(factor)
+  }
+
+  /**
+   * Get the exponential factor used to calculate the bitrate. Default 1f
+   */
+  override fun getBitrateExponentialFactor() = udpClient.getBitrateExponentialFactor()
 }

rtmp/src/main/java/com/pedro/rtmp/rtmp/RtmpClient.kt

@@ -602,4 +602,17 @@ class RtmpClient(private val connectChecker: ConnectChecker) {
   }
 
   fun getItemsInCache(): Int = rtmpSender.getItemsInCache()
+
+  /**
+   * @param factor values from 0.1f to 1f
+   * Set an exponential factor to the bitrate calculation to avoid bitrate spikes
+   */
+  fun setBitrateExponentialFactor(factor: Float) {
+    rtmpSender.setBitrateExponentialFactor(factor)
+  }
+
+  /**
+   * Get the exponential factor used to calculate the bitrate. Default 1f
+   */
+  fun getBitrateExponentialFactor() = rtmpSender.getBitrateExponentialFactor()
 }

rtmp/src/main/java/com/pedro/rtmp/rtmp/RtmpSender.kt

@@ -260,4 +260,10 @@ class RtmpSender(
   fun setLogs(enable: Boolean) {
     isEnableLogs = enable
   }
+
+  fun setBitrateExponentialFactor(factor: Float) {
+    bitrateManager.exponentialFactor = factor
+  }
+
+  fun getBitrateExponentialFactor() = bitrateManager.exponentialFactor
 }

rtsp/src/main/java/com/pedro/rtsp/rtsp/RtspClient.kt

@@ -502,4 +502,17 @@ class RtspClient(private val connectChecker: ConnectChecker) {
   }
 
   fun getItemsInCache(): Int = rtspSender.getItemsInCache()
+
+  /**
+   * @param factor values from 0.1f to 1f
+   * Set an exponential factor to the bitrate calculation to avoid bitrate spikes
+   */
+  fun setBitrateExponentialFactor(factor: Float) {
+    rtspSender.setBitrateExponentialFactor(factor)
+  }
+
+  /**
+   * Get the exponential factor used to calculate the bitrate. Default 1f
+   */
+  fun getBitrateExponentialFactor() = rtspSender.getBitrateExponentialFactor()
 }

rtsp/src/main/java/com/pedro/rtsp/rtsp/RtspSender.kt

@@ -272,4 +272,10 @@ class RtspSender(
   fun setLogs(enable: Boolean) {
     isEnableLogs = enable
   }
+
+  fun setBitrateExponentialFactor(factor: Float) {
+    bitrateManager.exponentialFactor = factor
+  }
+
+  fun getBitrateExponentialFactor() = bitrateManager.exponentialFactor
 }

srt/src/main/java/com/pedro/srt/srt/SrtClient.kt

@@ -429,4 +429,17 @@ class SrtClient(private val connectChecker: ConnectChecker) {
   }
 
   fun getItemsInCache(): Int = srtSender.getItemsInCache()
+
+  /**
+   * @param factor values from 0.1f to 1f
+   * Set an exponential factor to the bitrate calculation to avoid bitrate spikes
+   */
+  fun setBitrateExponentialFactor(factor: Float) {
+    srtSender.setBitrateExponentialFactor(factor)
+  }
+
+  /**
+   * Get the exponential factor used to calculate the bitrate. Default 1f
+   */
+  fun getBitrateExponentialFactor() = srtSender.getBitrateExponentialFactor()
 }

srt/src/main/java/com/pedro/srt/srt/SrtSender.kt

@@ -264,4 +264,10 @@ class SrtSender(
   fun setLogs(enable: Boolean) {
     isEnableLogs = enable
   }
+
+  fun setBitrateExponentialFactor(factor: Float) {
+    bitrateManager.exponentialFactor = factor
+  }
+
+  fun getBitrateExponentialFactor() = bitrateManager.exponentialFactor
 }

udp/src/main/java/com/pedro/udp/UdpClient.kt

@@ -276,4 +276,17 @@ class UdpClient(private val connectChecker: ConnectChecker) {
   }
 
   fun getItemsInCache(): Int = udpSender.getItemsInCache()
+
+  /**
+   * @param factor values from 0.1f to 1f
+   * Set an exponential factor to the bitrate calculation to avoid bitrate spikes
+   */
+  fun setBitrateExponentialFactor(factor: Float) {
+    udpSender.setBitrateExponentialFactor(factor)
+  }
+
+  /**
+   * Get the exponential factor used to calculate the bitrate. Default 1f
+   */
+  fun getBitrateExponentialFactor() = udpSender.getBitrateExponentialFactor()
 }

udp/src/main/java/com/pedro/udp/UdpSender.kt

@@ -264,4 +264,10 @@ class UdpSender(
   fun setLogs(enable: Boolean) {
     isEnableLogs = enable
   }
+
+  fun setBitrateExponentialFactor(factor: Float) {
+    bitrateManager.exponentialFactor = factor
+  }
+
+  fun getBitrateExponentialFactor() = bitrateManager.exponentialFactor
 }