Function _ticker

core/telegram_scanner.py:265–293

()

    stop_event = asyncio.Event()

    async def _ticker():
        nonlocal tick_bytes, total_bytes, last_data_time, last_nonzero_sec, peak_bps
        sec = 0
        while not stop_event.is_set():
            await asyncio.sleep(1.0)
            if t_start is None: continue
            sec += 1

            bps = tick_bytes
            tick_bytes = 0
            peak_bps = max(peak_bps, bps)
            elapsed = time.monotonic() - t_start

            if bps > 0:
                last_data_time = time.monotonic()
                last_nonzero_sec = sec

            avg = total_bytes / elapsed if elapsed > 0 else 0
            color = "green" if bps > 0 else "red"

            await display.update(0,
                f"[dim]В ПРОЦЕССЕ[/dim]  тек [{color}]{_fmt_speed(bps)}[/{color}]  "
                f"ср. [cyan]{_fmt_speed(avg)}[/cyan]  ({_fmt_size(total_bytes):>8} из {MEDIA_SIZE_MB}МБ)  ⏱ {sec:>2}с"
            )

            if time.monotonic() - last_data_time >= STALL_TIMEOUT:
                stop_event.set()
            if sec >= TOTAL_TIMEOUT:
                stop_event.set()

    async def _reader():
        nonlocal total_bytes, tick_bytes, t_start