OwlCyberSecurity - MANAGER
Edit File: _trio.cpython-312.pyc
� D��g $ � � � d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dlZ d dlm Z d dlmZmZmZmZmZ G d� de� Z G d� de� Z G d� d e� Zy) � N)�NullContext)�QUIC_MAX_DATAGRAM�AsyncQuicConnection�AsyncQuicManager�BaseQuicStream� UnexpectedEOFc �R � � e Zd Z� fd�Zd� Zd� Zd d�Zdd�Zd� Zd� Z d� Z d � Z� xZS )�TrioQuicStreamc �X �� t �| � ||� t j � | _ y �N)�super�__init__�trio� Condition�_wake_up)�self� connection� stream_id� __class__s ��=/opt/hc_python/lib/python3.12/site-packages/dns/quic/_trio.pyr zTrioQuicStream.__init__ s �� � ����Y�/����(�� � c � �& K � | j j |� ry || _ | j 4 �d { ��� | j j � � d { ��� d d d � �d { ��� d| _ �r7 �>7 �7 �# 1 �d { ���7 sw Y � xY w�w)Nr )�_buffer�have� _expectingr �wait)r �amounts r �wait_forzTrioQuicStream.wait_for sm � �� ���|�|� � ��(��$�D�O��}�}�}��m�m�(�(�*�*�*� %�}��D�O� � %��*�� %��}�}�}�sV �5B�A6�B�A<�A8�A<�B�)A:�* B�8A<�:B�<B�B�B� Bc � � K � | j j � ry | j 4 �d { ��� | j j � � d { ��� d d d � �d { ��� �c7 �77 �7 � # 1 �d { ���7 sw Y �xY w�wr )r �seen_endr r �r s r �wait_for_endzTrioQuicStream.wait_for_end'