common/com.pedro.common

Package-level declarations

Types

enum AudioCodec : Codec, Enum<AudioCodec>

object AudioUtils

class BitBuffer(val buffer: ByteBuffer)

Created by pedro on 9/12/23.

interface BitrateChecker

Created by pedro on 30/5/24.

open class BitrateManager(bitrateChecker: BitrateChecker)

Created by pedro on 8/04/21. Improved by perotom on 7/05/24.

class BufferPool(maxBuffersPerSizeClass: Int = 8, maxRetainedBytes: Long = 16 * 1024 * 1024)

Created by pedro on 29/7/26.

interface Codec

interface ConnectChecker : BitrateChecker

Created by pedro on 21/08/23.

ConnectCheckerEvent

interface ConnectCheckerEvent : ConnectChecker

Created by pedro on 8/3/24.

ConnectionFailed

enum ConnectionFailed : Enum<ConnectionFailed>

Created by pedro on 23/9/24.

object FpsUtils

class SpsH264Parser

Created by pedro on 27/07/26.

class SpsH265Parser

Created by pedro on 16/08/23.

StreamBlockingQueue

class StreamBlockingQueue(var capacity: Int)

enum StreamEvent : Enum<StreamEvent>

Created by pedro on 8/3/24.

StreamingStatsMonitor

class StreamingStatsMonitor(bitrateChecker: BitrateChecker)

Collects send-queue and throughput statistics each second and classifies bandwidth trends over a sliding window, mirroring HaishinKit NetworkMonitor behavior.

StreamingStatsReport

data class StreamingStatsReport(val bytesOutPerSecond: Long, val queueBytesOut: Long, val totalBytesOut: Long, val queueCongestionPercent: Float, val throughput: Throughput, val bitrate: Long, val smoothedBitrate: Long)

Per-second streaming statistics report.

enum Throughput : Enum<Throughput>

object TimeUtils

Created by pedro on 30/8/23.

class UrlParser

Created by pedro on 2/9/24.

enum VideoCodec : Codec, Enum<VideoCodec>

Functions

addressToString

fun InetAddress.addressToString(): String

Numeric IP as text, without reverse DNS lookup and without the IPv6 scope id (fe80::1%wlan0 -> fe80::1)

fun ByteArray.bytesToHex(): String

fun ByteBuffer.clone(): ByteBuffer

fun ByteBuffer.clone(data: ByteArray): ByteBuffer

fun List<ByteArray>.combine(): ByteArray

fun Long.compare(l: Long): Int

fun ByteBuffer.getData(): ByteArray

fun MediaFormat.getIntegerSafe(name: String): Int?

fun MediaFormat.getLongSafe(name: String): Long?

fun String.getMd5Hash(): String

getStartCodeSize

fun ByteBuffer.getStartCodeSize(): Int

getSuspendContext

fun getSuspendContext(dispatcher: CoroutineDispatcher = Dispatchers.IO): Continuation<Any?>

fun ByteBuffer.indicesOf(prefix: ByteArray): List<Int>

fun MediaCodec.BufferInfo.isKeyframe(): Boolean

Created by pedro on 3/11/23.

newSingleThreadExecutor

fun newSingleThreadExecutor(queue: LinkedBlockingQueue<Runnable>): ExecutorService

fun SecureRandom.nextBytes(size: Int): ByteArray

suspend fun onMainThread(code: () -> Unit)

onMainThreadHandler

fun onMainThreadHandler(code: () -> Unit)

fun ByteBuffer.put(buffer: ByteBuffer, offset: Int, length: Int)

fun InputStream.readUInt16(): Int

fun InputStream.readUInt24(): Int

fun InputStream.readUInt32(): Int

readUInt32LittleEndian

fun InputStream.readUInt32LittleEndian(): Int

fun InputStream.readUntil(byteArray: ByteArray)

fun ByteBuffer.removeHeader(): ByteBuffer

fun ByteBuffer.removeInfo(info: MediaFrame.Info): ByteBuffer

@RequiresApi(value = 21)

fun <T> CameraCharacteristics.secureGet(key: CameraCharacteristics.Key<T>): T?

@RequiresApi(value = 21)

fun <T> CaptureRequest.Builder.secureGet(key: CaptureRequest.Key<T>): T?

fun ExecutorService.secureSubmit(timeout: Long = 5000, code: () -> Unit)

fun BigInteger.toByteArray(length: Int): ByteArray

fun ByteBuffer.toByteArray(position: Int = 0, size: Int = limit()): ByteArray

fun Boolean.toInt(): Int

toMediaCodecBufferInfo

fun MediaFrame.Info.toMediaCodecBufferInfo(): MediaCodec.BufferInfo

toMediaFrameInfo

fun MediaCodec.BufferInfo.toMediaFrameInfo(): MediaFrame.Info

fun ByteArray.toUInt16(): Int

fun Int.toUInt16(): ByteArray

fun ByteArray.toUInt24(): Int

fun Int.toUInt24(): ByteArray

fun ByteArray.toUInt32(): Int

fun Int.toUInt32(): ByteArray

toUInt32LittleEndian

fun ByteArray.toUInt32LittleEndian(): Int

fun Int.toUInt32LittleEndian(): ByteArray

fun ByteArray.toUInt64(): Long

fun Long.toUInt64(): ByteArray

fun SurfaceTexture.tryClear()

infix inline fun <T : Any> BlockingQueue<T>.trySend(item: T): Boolean

fun Throwable.validMessage(): String

fun OutputStream.writeUInt16(value: Int)

fun OutputStream.writeUInt24(value: Int)

fun OutputStream.writeUInt32(value: Int)

fun ByteArray.writeUInt32(offset: Int, value: Int)

writeUInt32LittleEndian

fun OutputStream.writeUInt32LittleEndian(value: Int)

fun ByteArray.xorBytes(bytes: ByteArray): ByteArray