library/com.pedro.library.util.streamclient/RtmpStreamClient

RtmpStreamClient

class RtmpStreamClient(rtmpClient: RtmpClient, streamClientListener: StreamClientListener?) : StreamBaseClient

Created by pedro on 12/10/23.

Constructors

RtmpStreamClient

constructor(rtmpClient: RtmpClient, streamClientListener: StreamClientListener?)

Functions

addCertificates

fun addCertificates(certificates: TrustManager?)

Add certificates for TLS connection

clearCache

open override fun clearCache()

forceIncrementalTs

fun forceIncrementalTs(enabled: Boolean)

Some Livestream hosts use Akamai auth that requires RTMP packets to be sent with increasing timestamp order regardless of packet type. Necessary with Servers like Dacast. More info here: https://learn.akamai.com/en-us/webhelp/media-services-live/media-services-live-encoder-compatibility-testing-and-qualification-guide-v4.0/GUID-F941C88B-9128-4BF4-A81B-C2E5CFD35BBF.html

getBitrateExponentialFactor

open override fun getBitrateExponentialFactor(): Float

Get the exponential factor used to calculate the bitrate. Default 1f

getCacheSize

open override fun getCacheSize(): Int

getDroppedAudioFrames

open override fun getDroppedAudioFrames(): Long

getDroppedVideoFrames

open override fun getDroppedVideoFrames(): Long

getItemsInCache

open override fun getItemsInCache(): Int

getSentAudioFrames

open override fun getSentAudioFrames(): Long

getSentVideoFrames

open override fun getSentVideoFrames(): Long

hasCongestion

open override fun hasCongestion(percentUsed: Float): Boolean

fun hasCongestion(): Boolean

resetDroppedAudioFrames

open override fun resetDroppedAudioFrames()

resetDroppedVideoFrames

open override fun resetDroppedVideoFrames()

resetSentAudioFrames

open override fun resetSentAudioFrames()

resetSentVideoFrames

open override fun resetSentVideoFrames()

resizeCache

open override fun resizeCache(newSize: Int)

reTry

open override fun reTry(delay: Long, reason: String, backupUrl: String?): Boolean

Retries to connect with the given delay. You can pass an optional backupUrl if you'd like to connect to your backup server instead of the original one. Given backupUrl replaces the original one.

fun reTry(delay: Long, reason: String): Boolean

setAuthorization