[fix] Test for closed channel

mosquito · Feb 17, 2020 · d5a4bac · d5a4bac
1 parent 56bf42c
commit d5a4bac
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/tests/test_amqp.py b/tests/test_amqp.py
@@ -10,6 +10,8 @@
 
 import pytest
 import shortuuid
+
+import aiormq.exceptions
 from aiormq import ChannelLockedResource
 
 import aio_pika
@@ -1104,6 +1106,9 @@ async def test_unexpected_channel_close(self):
             await channel.declare_queue("amq.restricted_queue_name",
                                         auto_delete=True)
 
+        with pytest.raises(aiormq.exceptions.ChannelInvalidStateError):
+            await channel.set_qos(100)
+
         await asyncio.wait((client.close(), client.closing))
 
     async def test_declaration_result(self):