File: //snap/core22/current/usr/share/subiquity/subiquitycore/__pycache__/pubsub.cpython-310.pyc
o
K��^� � @ s0 d dl Z d dlZG dd� d�ZG dd� d�ZdS )� Nc @ s e Zd ZdZdS )� CoreChannelsz
network-upN)�__name__�
__module__� __qualname__�
NETWORK_UP� r r �,/usr/share/subiquity/subiquitycore/pubsub.pyr s r c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
�
MessageHubc C s
i | _ d S �N)�
subscriptions)�selfr r r �__init__ s
zMessageHub.__init__c C s | j �|g ��|� d S r
)r �
setdefault�append)r �channel�methodr r r � subscribe s zMessageHub.subscribec � s< �| j �|g �D ]}||i |��}t�|�r|I d H qd S r
)r �get�inspect� iscoroutine)r r �args�kwargs�m�vr r r �
abroadcast s �
��zMessageHub.abroadcastc O s& t �� }|�| j|g|�R i |���S r
)�asyncio�get_event_loop� create_taskr )r r r r �loopr r r � broadcast% s zMessageHub.broadcastN)r r r r
r r r r r r r r s
r )r r r r r r r r �<module> s