B
    f’»dç  ã               @   sN   d dl Z d dlmZmZ d dlmZ ddlmZ e  e	¡Z
G dd„ deƒZdS )é    N)ÚpackÚunpack)ÚOptionalé   )ÚTCPc                   sb   e Zd Zeedœ‡ fdd„Zedœ‡ fdd„Zedœ‡ fdd	„Z	de
ee dœ‡ fdd„Z‡  ZS )ÚTCPIntermediate)Úipv6Úproxyc                s   t ƒ  ||¡ d S )N)ÚsuperÚ__init__)Úselfr   r	   )Ú	__class__© úV/tmp/pip-unpacked-wheel-rcokkf2l/pyrogram/connection/transport/tcp/tcp_intermediate.pyr      s    zTCPIntermediate.__init__)Úaddressc             ƒ   s(   t ƒ  |¡I d H  t ƒ  d¡I d H  d S )Ns   îîîî)r
   ÚconnectÚsend)r   r   )r   r   r   r       s    zTCPIntermediate.connect)Údatac             ‡   s$   t ƒ  tdt|ƒƒ| ¡I d H  d S )Nz<i)r
   r   r   Úlen)r   r   Úargs)r   r   r   r   $   s    zTCPIntermediate.sendr   )ÚlengthÚreturnc             ƒ   s:   t ƒ  d¡I d H }|d krd S t ƒ  td|ƒd ¡I d H S )Né   z<ir   )r
   Úrecvr   )r   r   )r   r   r   r   '   s    zTCPIntermediate.recv)r   )Ú__name__Ú
__module__Ú__qualname__ÚboolÚdictr   Útupler   Úbytesr   Úintr   r   Ú__classcell__r   r   )r   r   r      s   r   )ÚloggingÚstructr   r   Útypingr   Ztcpr   Ú	getLoggerr   Úlogr   r   r   r   r   Ú<module>   s
   
