Closed adamhooper closed 3 years ago
@ASYNC_TEST async def test_publish_after_disconnect(connection): await connection.close() with pytest.raises(carehare.ConnectionClosed): await connection.publish(b"foo", routing_key="messages")
Expected results: raise carehare.ConnectionClosed Actual results: stall
carehare.ConnectionClosed
Expected results: raise
carehare.ConnectionClosed
Actual results: stall