diff --git a/hbmqtt/broker/handlers/connect.py b/hbmqtt/broker/handlers/connect.py
index eec9c23..e5cf57e 100644
--- a/hbmqtt/broker/handlers/connect.py
+++ b/hbmqtt/broker/handlers/connect.py
@@ -2,12 +2,14 @@
 #
 # See the file license.txt for copying permission.
 
+import asyncio
 from hbmqtt.message import MQTTMessage, ConnectMessage
 
 class ConnectHandler:
     def __init__(self, broker):
         self._broker = broker
 
+    @asyncio.coroutine
     def handle(message: ConnectMessage) -> MQTTMessage:
         # TBD
         pass
\ No newline at end of file