chore: rm loop from __init__

decaz · Oct 11, 2023 · ff3cc46 · ff3cc46
1 parent c3d44ee
commit ff3cc46
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/docs/source/rabbitmq-tutorial/examples/6-rpc/rpc_client.py b/docs/source/rabbitmq-tutorial/examples/6-rpc/rpc_client.py
@@ -15,7 +15,6 @@ class FibonacciRpcClient:
 
     def __init__(self) -> None:
         self.futures: MutableMapping[str, asyncio.Future] = {}
-        self._loop = asyncio.get_running_loop()
 
     async def connect(self) -> "FibonacciRpcClient":
         self.connection = await connect("amqp://guest:guest@localhost/")
@@ -35,7 +34,8 @@ async def on_response(self, message: AbstractIncomingMessage) -> None:
 
     async def call(self, n: int) -> int:
         correlation_id = str(uuid.uuid4())
-        future = self._loop.create_future()
+        loop = asyncio.get_running_loop()
+        future = loop.create_future()
 
         self.futures[correlation_id] = future