Function run_shared_decode_pump_blocking 

pub fn run_shared_decode_pump_blocking(
    cfg: DecodePumpConfig,
    input_data: Bytes,
    senders: Vec<Sender<VideoFrame>>,
    rt: Handle,
) -> Result<u64>

Blocking decode loop, designed for tokio::task::spawn_blocking. Fans every normalized frame out to all senders. If a sender’s channel is closed (its rung gave up) the pump continues with the rest; it stops only when every sender is closed. rt bridges into the async send().await.

Returns the number of frames pushed.