/usr/lib/python3/dist-packages/jeepney/integrate/__pycache__
Edit: /usr/lib/python3/dist-packages/jeepney/integrate/__pycache__/asyncio.cpython-310.pyc (4149B)
o
` @ s d Z ddlZddlmZ ddlmZmZ ddlmZm Z m
Z
m Z ddl m
Z
ddlmZ ddlmZ dd lmZ ed
d d G d
d dejZG dd deZdddZdS )z*Deprecated: use jeepney.io.asyncio instead N)warn)Parser MessageType)AuthenticationErrorBEGINmake_auth_external
SASLParser)get_bus) message_bus)Router) ProxyBasezOjeepney.integrate.asyncio is deprecated: please use jeepney.io.asyncio instead. )
stacklevelc @ sD e Zd Zdd Zdd Zdd Zdd Zd d
Zd d Zd
d Z dS ) DBusProtocolc C s0 t | _t | _ttj| _t | _d | _ d S N)
r auth_parserr parserr asyncioFuturerouterauthentication unique_nameself r ;/usr/lib/python3/dist-packages/jeepney/integrate/asyncio.py__init__ s
zDBusProtocol.__init__c C s || _ | j dt d S )N ) transportwriter )r r r r r connection_made s z DBusProtocol.connection_madec C s2 | j t | jd | j| _| | jj d S )NT) r r r r
set_resultdata_received_post_auth
data_receivedr bufferr r r r _authenticated s zDBusProtocol._authenticatedc C sD | j | | j jr| d S | j jr | jt| j j d S d S r )r feed
authenticatedr% errorr
set_exceptionr )r datar r r r# ! s zDBusProtocol.data_receivedc C s" | j |D ]}| j| qd S r )r r& r incoming)r r* msgr r r r" ( s z$DBusProtocol.data_received_post_authc C s6 | j s td| j|}| }| j| |S )Nz/Wait for authentication before sending messages)r done RuntimeErrorr outgoing serialiser r )r messagefuturer* r r r send_message, s
zDBusProtocol.send_messagec s( |j jtjkr td| |I d H S )Nz&Only method call messages have replies)header message_typer method_call TypeErrorr3 )r r1 r r r send_and_get_reply5 s z DBusProtocol.send_and_get_replyN)
__name__
__module__ __qualname__r r r% r# r" r3 r8 r r r r r s r c s0 e Zd ZdZ fddZdd Zdd Z ZS )ProxyzAn asyncio proxy for calling D-Bus methods
:param msggen: A message generator object.
:param DBusProtocol proto: Protocol object to send and receive messages.
c s t | || _d S r )superr _protocol)r msggenprotocol __class__r r r A s
zProxy.__init__c C s d | j| jS )Nz
Proxy({}, {}))format_msggenr> r r r r __repr__E s zProxy.__repr__c s fdd}|S )Nc s4 | i |}|j jtju sJ j|I d H S r )r4 r5 r r6 r> r8 )argskwargsr, make_msgr r r innerI s z!Proxy._method_call.
.innerr )r rI rJ r rH r _method_callH s zProxy._method_call)r9 r: r; __doc__r rE rK
__classcell__r r rA r r< ; s
r< SESSIONc sd |d u r t }|jtt| dI d H \}}|jI d H tt|} | I d H }|d |_ ||fS )N)pathr )
r get_event_loopcreate_unix_connectionr r r r< r
Hellor )buslooptp hello_replyr r r connect_and_authenticateQ s
rX )rN N)rL r warningsr jeepneyr r jeepney.authr r r r jeepney.busr jeepney.bus_messagesr
jeepney.routingr jeepney.wrappersr Protocolr r< rX r r r r s ,