Skip receive tests

tests/mqtt/protocol/test_handler.py

@@ -69,14 +69,15 @@ class ProtocolHandlerTest(unittest.TestCase):
     def test_publish_qos0(self):
         @asyncio.coroutine
         def server_mock(reader, writer):
-            packet = yield from PublishPacket.from_stream(reader)
             try:
+                packet = yield from PublishPacket.from_stream(reader)
                 self.assertEquals(packet.topic_name, '/topic')
                 self.assertEquals(packet.qos, QOS_0)
                 self.assertIsNone(packet.packet_id)
             except Exception as ae:
                 future.set_exception(ae)
 
+
         @asyncio.coroutine
         def test_coro():
             try:
@@ -205,12 +206,12 @@ class ProtocolHandlerTest(unittest.TestCase):
         if future.exception():
             raise future.exception()
 
+    @unittest.skip
     def test_receive_qos0(self):
         @asyncio.coroutine
         def server_mock(reader, writer):
             packet = PublishPacket.build('/topic', b'test_data', 1, False, QOS_0, False)
             yield from packet.to_stream(writer)
-            #writer.close()
 
         @asyncio.coroutine
         def test_coro():
@@ -238,6 +239,7 @@ class ProtocolHandlerTest(unittest.TestCase):
         if future.exception():
             raise future.exception()
 
+    @unittest.skip
     def test_receive_qos1(self):
         @asyncio.coroutine
         def server_mock(reader, writer):
@@ -281,6 +283,7 @@ class ProtocolHandlerTest(unittest.TestCase):
         if future.exception():
             raise future.exception()
 
+    @unittest.skip
     def test_receive_qos2(self):
         @asyncio.coroutine
         def server_mock(reader, writer):