test

                    }

                    if (empty_streak >= max_empty)

                        break;

                    // Yield briefly but don't add excessive latency

                    std::this_thread::yield();

                    // Sleep briefly to give upstream time to produce data.

                    // yield() is essentially a no-op on Linux and burns

                    // through max_empty in microseconds, causing premature

                    // stream termination (504) for slow upstreams.

                    std::this_thread::sleep_for(std::chrono::milliseconds(10));

                }

            }