[fix] rpc_client loop

mosquito · Sep 28, 2019 · 4f0a301 · 4f0a301
1 parent dd4f663
commit 4f0a301
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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