_1hG pdZddlmZmZmZddlmZmZmZddl m Z ddl m Z ddlm Z dZGd d Zd Zy ) z. wsproto ~~~~~~~ A WebSocket implementation. ) GeneratorOptionalUnion) ConnectionConnectionStateConnectionType)Event) H11Handshake)Headersz1.2.0ceZdZdZdeddfdZedefdZde de e e fddfd Z d ede fd Zd ee ddfd ZdeeddffdZy) WSConnectionzN Represents the local end of a WebSocket connection to a remote peer. connection_typereturnNc`|tju|_t||_d|_y)z Constructor :param wsproto.connection.ConnectionType connection_type: Controls whether the library behaves as a client or as a server. N)r CLIENTclientr handshake connection)selfrs N/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/wsproto/__init__.py__init__zWSConnection.__init__s)&)>)>> %o604cr|j|jjS|jjS)z_ :returns: Connection state :rtype: wsproto.connection.ConnectionState )rrstaters rrzWSConnection.state!s. ?? ">>'' '$$$rheaderspathc<|jj||y)N)rinitiate_upgrade_connection)rrrs rr z(WSConnection.initiate_upgrade_connection+s 227DAreventcd}|j;||jj|z }|jj|_|S||jj|z }|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 r)rrsend)rr!datas rr#zWSConnection.send0sd ?? " DNN''. .D"nn77DO  DOO((/ /D rr$c|j7|jj||jj|_y|jj|y)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)rr$s rr&zWSConnection.receive_dataCsC ?? " NN ' ' -"nn77DO OO ( ( .rc#K|jjEd{|j#|jjEd{yy747w)z A generator that yields pending events. Each event is an instance of a subclass of :class:`wsproto.events.Event`. N)reventsrrs rr(zWSConnection.eventsRsL>>((*** ?? &--/ / / ' + /s!AA-AAAA)__name__ __module__ __qualname____doc__r rpropertyrrr rbytesstrr r r#rr&rr(rrrrs 5 54 5%%%BB&+E3J&7B B %E& /% /T / 0 %t"34 0rr)r rN)r,typingrrrrrrr r(r rr r __version__r__all__r0rrr4s: .-CC# J0J0Z -r