Format: application/x-python-code
1 o
2
3 7'h� � @ s� d dl mZ d dlZd dlZd dlZddlmZmZmZm Z m
4 Z
5 m Z m Z ddl
6 mZ ddlmZmZmZ G dd � d e�ZG d
7 d � d e�ZdS ) � )� annotationsN� )� ConnectError�ConnectTimeout� ReadError� ReadTimeout�
8 WriteError� WriteTimeout�map_exceptions)�is_socket_readable� )�
9 SOCKET_OPTION�AsyncNetworkBackend�AsyncNetworkStreamc @ sR e Zd Zd dd�Zd!d"d
10 d�Zd!d#dd�Zd$dd�Z d%d&dd�Zd'd d �ZdS )(� AnyIOStream�stream�anyio.abc.ByteStream�return�Nonec C s
11 || _ d S �N)�_stream)�selfr � r �NC:\Users\shubh\Videos\agent\nova\Lib\site-packages\httpcore/_backends/anyio.py�__init__ s
12 zAnyIOStream.__init__N� max_bytes�int�timeout� float | None�bytesc
13 � s� �t ttjttjttjti}t|��H t�|��2 z| j j
14 |d�I d H W W d � W d � S tjyI Y W d � W d � dS w 1 sMw Y W d � d S 1 s]w Y d S )N)r � ) � TimeoutErrorr �anyio�BrokenResourceErrorr �ClosedResourceError� EndOfStreamr
15 �
16 fail_afterr Zreceive)r r r �exc_mapr r r �read s& ��
17 �� ���"�zAnyIOStream.read�bufferc � s� �|sd S t ttjttjti}t|��0 t�|�� | jj |d�I d H W d � n1 s.w Y W d � d S W d � d S 1 sFw Y d S )N)�item)
18 r! r r" r# r r$ r
19 r& r �send)r r) r r' r r r �write' s ��
20 ��"�zAnyIOStream.writec � s �| j �� I d H d S r )r �aclose)r r r r r- 4 � �zAnyIOStream.aclose� ssl_context�ssl.SSLContext�server_hostname�
21 str | Noner c � s� �t ttjttjttjti}t|��I z(t� |�� tj
22 j j j
23 | j||ddd�I d H }W d � n1 s5w Y W n tyP } z | �� I d H |�d }~ww W d � t|�S 1 s^w Y t|�S )NF)r/ �hostnameZstandard_compatible� server_side)r! r r" r# r r% �ssl�SSLErrorr
24 r& �streams�tlsZ TLSStream�wrapr � Exceptionr- r )r r/ r1 r r' Z
25 ssl_stream�excr r r � start_tls7 s8 ��
26
27 � �����
28 �
29 �
30 zAnyIOStream.start_tls�info�str�
31 typing.Anyc C s� |dkr| j �tjjjjd �S |dkr | j �tjjj d �S |dkr+| j �tjjj
32 d �S |dkr9| j �tjjj d �S |dkrK| j �tjjj d �}t |�S d S )N�
33 ssl_object� client_addrZ server_addr�socketZ is_readable)
34 r �extrar" r7 r8 Z TLSAttributer@ �abcZSocketAttribute�
35 local_address�remote_addressZ
36 raw_socketr )r r= �sockr r r �get_extra_infoR s zAnyIOStream.get_extra_info)r r r r r )r r r r r r )r) r r r r r )r r �NN)r/ r0 r1 r2 r r r r )r= r> r r? ) �__name__�
37 __module__� __qualname__r r( r, r- r< rH r r r r r s
38
39
40 �r c @ s8 e Zd Z dddd�Z dddd�Zd dd�ZdS ) � AnyIOBackendN�hostr> �portr r r rE r2 �socket_options�%typing.Iterable[SOCKET_OPTION] | Noner r c � s� �|d u rg }t ttttjti}t|��@ t�|�� tj|||d�I d H }|D ]}|j j
41 |� q(W d � n1 s;w Y W d � t |�S W d � t |�S 1 sWw Y t |�S )N)Z remote_hostZ remote_portZ
42 local_host) r! r �OSErrorr r" r# r
43 r& � connect_tcp� _raw_socket�
44 setsockoptr ) r rN rO r rE rP r' r �optionr r r rS b s2 ��
45 �� �
46 �
47 �
48 �
49 �
50 zAnyIOBackend.connect_tcp�pathc � s� �|d u rg }t ttttjti}t|��= t�|�� t�|�I d H }|D ]}|j j
51 |� q%W d � n1 s8w Y W d � t |�S W d � t |�S 1 sTw Y t |�S r ) r! r rR r r" r# r
52 r& Z connect_unixrT rU r )r rW r rP r' r rV r r r �connect_unix_socket} s* ��
53 � �
54 ��
55 ��z AnyIOBackend.connect_unix_socket�seconds�floatr c � s �t �|�I d H d S r )r" �sleep)r rY r r r r[ � r. zAnyIOBackend.sleep)NNN) rN r> rO r r r rE r2 rP rQ r r rI )rW r> r r rP rQ r r )rY rZ r r )rJ rK rL rS rX r[ r r r r rM a s � �rM )�
56 __future__r r5 �typingr" � _exceptionsr r r r r r r
57 �_utilsr �baser
58 r r r rM r r r r �<module> s $ L