o
    FDi                     @   s*   d dl mZ d dlmZ G dd dZdS )    )	constants)BufferedReaderc                   @   s*   e Zd ZdefddZdd Zdd ZdS )	Progressreaderc                 C   s(   d| _ d| _d| _d| _d| _|| _d S )Nr   )rowsbytes
total_rowswritten_rowswritten_bytesr   )selfr    r   N/var/www/Datamplify/venv/lib/python3.10/site-packages/asynch/proto/progress.py__init__   s   
zProgress.__init__c                    s|   | j  I d H | _| j  I d H | _|}|tjkr#| j  I d H | _|tjkr<| j  I d H | _| j  I d H | _	d S d S N)
r   read_varintr   r   r   -DBMS_MIN_REVISION_WITH_TOTAL_ROWS_IN_PROGRESSr   (DBMS_MIN_REVISION_WITH_CLIENT_WRITE_INFOr	   r
   )r   server_revisionrevisionr   r   r   read   s   

zProgress.readc                 C   sT   |  j |j 7  _ |  j|j7  _|  j|j7  _|  j|j7  _|  j|j7  _d S r   )r   r   r   r	   r
   )r   another_progressr   r   r   	increment   s
   zProgress.incrementN)__name__
__module____qualname__r   r   r   r   r   r   r   r   r      s    r   N)asynch.protor   asynch.proto.streams.bufferedr   r   r   r   r   r   <module>   s    