diff --git a/docs/source/rabbitmq-tutorial/examples/6-rpc/rpc_client.py b/docs/source/rabbitmq-tutorial/examples/6-rpc/rpc_client.py index ce2f3219..08c1b240 100644 --- a/docs/source/rabbitmq-tutorial/examples/6-rpc/rpc_client.py +++ b/docs/source/rabbitmq-tutorial/examples/6-rpc/rpc_client.py @@ -29,7 +29,7 @@ def on_response(self, message: IncomingMessage): async def call(self, n): correlation_id = str(uuid.uuid4()) - future = loop.create_future() + future = self.loop.create_future() self.futures[correlation_id] = future