File: //usr/local/lib/python3.10/dist-packages/openai/cli/__pycache__/_progress.cpython-310.pyc
o
���g~ � @ sf d dl mZ d dlZd dlmZ d dlmZ G dd� de�ZG dd� dej �Z
ddd�Z ddd�Z dS )� )� annotationsN)�Callable)�overridec s0 e Zd Zd � fdd� Zed
dd��ZeZ� ZS ) �CancelledError�msg�str�return�Nonec s || _ t� �|� d S �N)r �super�__init__)�selfr �� __class__� �?/usr/local/lib/python3.10/dist-packages/openai/cli/_progress.pyr s zCancelledError.__init__c C � | j S r
)r �r
r r r �__str__
s zCancelledError.__str__)r r r r )r r )�__name__�
__module__� __qualname__r r r �__repr__�
__classcell__r r r r r s
r c s: e Zd Zdd� fd d
�
Zdd d
�Zedddd��Z� ZS )� BufferReader� N�buf�bytes�desc�
str | Noner r c s2 t � �|� t|�| _d| _tt|�|d�| _d S )Nr )r )r r �len�_len� _progress�progress� _callback)r
r r r r r r s
zBufferReader.__init__�intc C r r
)r! r r r r �__len__ s zBufferReader.__len__����n�
int | Nonec
C s\ t j�| |�}| jt|�7 _z | �| j� W |S ty- } ztd�|��|�d }~ww )Nz The upload was cancelled: {}) �io�BytesIO�readr" r r$ � Exceptionr �format)r
r( �chunk�er r r r, s ���zBufferReader.read)r N)r r r r r r )r r% )r' )r( r) r r )r r r r r& r r, r r r r r r s
r �total�floatr r r �Callable[[float], None]c s, dd l }|j �d|d�� d
� �fdd � }|S ) Nr T)r1 �
unit_scaler r# r2 r r c s& | � _ | �kr
� �� d S � �� d S r
)r( �close�refresh)r# ��meterr1 r r �incr0 s zprogress.<locals>.incr)r# r2 r r )�tqdm)r1 r r: r9 r r7 r r# + s r# �ir% c C s t | d �S )Ni )r% )r; r r r �MB: s r< )r1 r2 r r r r3 )r; r% r r% )
�
__future__r r* �typingr �typing_extensionsr r- r r+ r r# r< r r r r �<module> s