process Consumer Transports
Processes consumer transports to pause or resume video streams based on provided stream lists.
This function iterates over consumer transports, checking if each transport's producerId matches any in the provided lists of streams. It then pauses or resumes consumers accordingly.
Features:
Consumer transport processing
Stream-based pause/resume logic
Audio transport handling (no-op)
Error handling and recovery
Parameters:
options Configuration options for processing consumer transports
Returns:
Example Usage:
val options = ProcessConsumerTransportsOptions(
consumerTransports = myTransportInfos,
lStreams_ = myStreams,
parameters = myParameters
)
val result = processConsumerTransports(options)
result.onSuccess {
}
result.onFailure { error ->
Logger.e("ProcessConsumerTrans", "Error processing consumer transports: ${error.message}")
}Content copied to clipboard