Source code for reemote.callbacks.progress.rate_limiting_progress_updates

# Copyright (c) 2025 Kim Jarvis TPF Software Services S.A. kim.jarvis@tpfsystems.com 
# This software is licensed under the MIT License. See the LICENSE file for details.
#
import time



[docs]
class Rate_limiting_progress_updates:
    """
    Progress handler that throttles updates to avoid flooding

    Args:
        src_path: Source builtin path
        dst_path: Destination builtin path
        copied_bytes: Number of bytes copied so far
        total_bytes: Total bytes to copy (None if unknown)
    """
    def __init__(self, min_interval=0.1):  # Update at most every 100ms
        self.min_interval = min_interval
        self.last_update = 0

    def __call__(self, src_path, dst_path, copied_bytes, total_bytes):
        current_time = time.time()
        if current_time - self.last_update >= self.min_interval:
            if total_bytes:
                percentage = (copied_bytes / total_bytes) * 100
                print(f"Progress: {percentage:.1f}% ({copied_bytes}/{total_bytes} bytes)")
            else:
                print(f"Progress: {copied_bytes} bytes copied")
            self.last_update = current_time