common/com.pedro.common/StreamBlockingQueue

StreamBlockingQueue

class StreamBlockingQueue(var capacity: Int)

Constructors

StreamBlockingQueue

constructor(capacity: Int)

Properties

var capacity: Int

Functions

fun clear(onRemove: (MediaFrame) -> Unit? = null)

fun drainTo(destiny: StreamBlockingQueue)

fun getSize(): Int

fun getTotalSize(): Long

Sum of MediaFrame.info.size for all frames in the main send queue. Delay/cache queue bytes are excluded.

remainingCapacity

fun remainingCapacity(): Int

fun setCacheTime(cache: Long)

fun take(): MediaFrame

fun trySend(item: MediaFrame): Boolean