diff --git a/hbmqtt/client/_client.py b/hbmqtt/client/_client.py
index 025a2fa..eef7ae1 100644
--- a/hbmqtt/client/_client.py
+++ b/hbmqtt/client/_client.py
@@ -174,7 +174,7 @@ class MQTTClient:
 
     @asyncio.coroutine
     def subscribe(self, topics):
-        yield from self._handler.mqtt_subscribe(topics, self.session.next_packet_id)
+        return (yield from self._handler.mqtt_subscribe(topics, self.session.next_packet_id))
 
     @asyncio.coroutine
     def unsubscribe(self, topics):