o RhG @sjdZddlmZmZmZddlmZmZmZddl m Z ddl m Z ddlm Z dZGd d d Zd Zd S) z. wsproto ~~~~~~~ A WebSocket implementation. ) GeneratorOptionalUnion) ConnectionConnectionStateConnectionType)Event) H11Handshake)Headersz1.2.0c@seZdZdZdeddfddZedefddZd e d e e e fddfd d Z d ede fddZdee ddfddZdeeddffddZdS) WSConnectionzN Represents the local end of a WebSocket connection to a remote peer. connection_typereturnNcCs |tju|_t||_d|_dS)z Constructor :param wsproto.connection.ConnectionType connection_type: Controls whether the library behaves as a client or as a server. N)rCLIENTclientr handshake connection)selfr rR/home/air/sanwanet/backup_V2/venv/lib/python3.10/site-packages/wsproto/__init__.py__init__s   zWSConnection.__init__cCs|jdur |jjS|jjS)z_ :returns: Connection state :rtype: wsproto.connection.ConnectionState N)rrstaterrrrr!s zWSConnection.stateheaderspathcCs|j||dS)N)rinitiate_upgrade_connection)rrrrrrr+sz(WSConnection.initiate_upgrade_connectioneventcCs@d}|jdur||j|7}|jj|_|S||j|7}|S)a Generate network data for the specified event. When you want to communicate with a WebSocket peer, you should construct an event and pass it to this method. This method will return the bytes that you should send to the peer. :param wsproto.events.Event event: The event to generate data for :returns bytes: The data to send to the peer N)rrsend)rrdatarrrr0s  zWSConnection.sendrcCs4|jdur|j||jj|_dS|j|dS)z Feed network data into the connection instance. After calling this method, you should call :meth:`events` to see if the received data triggered any new events. :param bytes data: Data received from remote peer N)rr receive_data)rrrrrr Cs zWSConnection.receive_dataccs4|jEdH|jdur|jEdHdSdS)z A generator that yields pending events. Each event is an instance of a subclass of :class:`wsproto.events.Event`. N)reventsrrrrrr!Rs  zWSConnection.events)__name__ __module__ __qualname____doc__rrpropertyrrr rbytesstrrr rrr rr!rrrrr s    r )rr N)r%typingrrrrrrrr!r rr r __version__r __all__rrrrs   M