/opt/imunify360/venv/lib/python3.11/site-packages/nats/aio/__pycache__
� ��9?��G� �� � d dl mZ d dlZd dlZd dlZd dlmZmZmZm Z d dl mZ d dlZd dl Z n# e$ r dZdZ Y nw xY wd dlmZ G d� dej � � Z G d� d e� � Z G d � de� � ZdS )� )�annotationsN)�Dict�List�Optional�Union)�ParseResult)� ProtocolErrorc �| � e Zd Zej dd�� � Zej dd �� � Zej dd �� � Zej dd�� � Zej dd�� � Z ej dd�� � Z ej d� � � Zej d� � � Zej d� � � Z ej d d�� � Zej d� � � ZdS )!� Transport�urir �buffer_size�int�connect_timeoutc � � K � dS )z� Connects to a server using the implemented transport. The uri passed is of type ParseResult that can be obtained calling urllib.parse.urlparse. N� )�selfr r r s �r/builddir/build/BUILD/imunify360-venv-2.6.2/opt/imunify360/venv/lib/python3.11/site-packages/nats/aio/transport.py�connectzTransport.connect � � � � � �� �Union[str, ParseResult]�ssl_context�ssl.SSLContextc � � K � dS )a$ connect_tls is similar to connect except it tries to connect to a secure endpoint, using the provided ssl context. The uri can be provided as string in case the hostname differs from the uri hostname, in case it was provided as 'tls_hostname' on the options. Nr )r r r r r s r �connect_tlszTransport.connect_tls s � � � � �r �payload�bytesc � � dS )zj Write bytes to underlying transport. Needs a call to drain() to be successfully written. Nr �r r s r �writezTransport.write+ � � � �r �List[bytes]c � � dS )z� Writes a list of bytes, one by one, to the underlying transport. Needs a call to drain() to be successfully written. Nr r s r � writelineszTransport.writelines2 s � � �r �returnc � � K � dS )z� Reads a sequence of bytes from the underlying transport, up to buffer_size. The buffer_size is ignored in case the transport carries already frames entire messages (i.e. websocket). Nr �r r s r �readzTransport.read: r r c � � K � dS )z\ Reads one whole frame of bytes (or message) from the underlying transport. Nr �r s r �readlinezTransport.readlineB � � � � � �r c � � K � dS )zb Flushes the bytes queued for transmission when calling write() and writelines(). Nr r* s r �drainzTransport.drainI r, r c � � K � dS )zD Waits until the connection is successfully closed. Nr r* s r �wait_closedzTransport.wait_closedP r, r c � � dS )z2 Closes the underlying transport. Nr r* s r �closezTransport.closeW r! r �boolc � � dS )z< Returns if underlying transport is at eof. Nr r* s r �at_eofzTransport.at_eof^ r! r c � � dS )ze Returns if the transport was initialized, either by calling connect of connect_tls. Nr r* s r �__bool__zTransport.__bool__e r! r N�r r r r r r �r r r r r r r r )r r )r r"