mirror
/
amqtt
kopia lustrzana https://github.com/Yakifo/amqtt
1
0
Forkuj 0
Kod Zgłoszenia Packages Projekty Wydania Wiki Aktywność

Move to coroutine

pull/8/head
Nicolas Jouanin 2015-06-08 22:11:24 +02:00
rodzic a9649d8108
commit 7605a18a3d
1 zmienionych plików z 2 dodań i 0 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

2
hbmqtt/broker/handlers/connect.py
Wyświetl plik

@ -2,12 +2,14 @@
# #
# See the file license.txt for copying permission. # See the file license.txt for copying permission.
import asyncio
from hbmqtt.message import MQTTMessage, ConnectMessage from hbmqtt.message import MQTTMessage, ConnectMessage
class ConnectHandler: class ConnectHandler:
def __init__(self, broker): def __init__(self, broker):
self._broker = broker self._broker = broker
@asyncio.coroutine
def handle(message: ConnectMessage) -> MQTTMessage: def handle(message: ConnectMessage) -> MQTTMessage:
# TBD # TBD
pass pass