test: added some testing for the doc code snippet

docs/docs_src/rabbit/bind.py

@@ -10,20 +10,24 @@
 app = FastStream(broker)
 
 
+some_queue = RabbitQueue(
+    name="some-queue",
+    durable=True,
+)
+
+some_exchange = RabbitExchange(
+    name="some-exchange",
+    type=ExchangeType.FANOUT,
+)
+
 @app.after_startup
 async def bind_queue_exchange():
     queue = await broker.declare_queue(
-        RabbitQueue(
-            name="some-queue",
-            durable=True,
-        )
+        some_queue
     ) # This gives a aio_pika.RobustQueue object
 
     exchange = await broker.declare_exchange(
-        RabbitExchange(
-            name="some-exchange",
-            type=ExchangeType.FANOUT,
-        )
+        some_exchange
     )
 
     await queue.bind(

tests/a_docs/rabbit/test_bind.py

@@ -0,0 +1,29 @@
+from unittest.mock import AsyncMock
+
+import pytest
+from aio_pika import RobustQueue
+
+from faststream import TestApp
+from tests.marks import require_aiopika
+
+
+@pytest.mark.asyncio
+@pytest.mark.rabbit
+@require_aiopika
+async def test_bind(monkeypatch, async_mock: AsyncMock):
+    from docs.docs_src.rabbit.bind import app, broker, some_exchange, some_queue
+
+    with monkeypatch.context() as m:
+        m.setattr(RobustQueue, "bind", async_mock)
+        async with TestApp(app):
+            assert len(broker.declarer._RabbitDeclarer__queues) == 2  # with `reply-to`
+            assert len(broker.declarer._RabbitDeclarer__exchanges) == 1
+
+            assert some_queue in broker.declarer._RabbitDeclarer__queues
+            assert some_exchange in broker.declarer._RabbitDeclarer__exchanges
+
+            async_mock.assert_awaited_once_with(
+                queue=broker.declarer._RabbitDeclarer__queues[some_queue],
+                exchange=broker.declarer._RabbitDeclarer__exchanges[some_exchange],
+                routing_key=some_queue.name,
+            )