processConsumerTransports

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}")
}