io.asyncioreactor: fix deprecated usages for working with python>=3.10

* stop using the loop argument for `asyncio.Lock` and asyncio.Quoue`
* on the lock replace `with await` with `async with`, which is the correct
  syntax for using that lock

Author: fruch

cassandra/io/asyncioreactor.py

@@ -1,5 +1,5 @@
 from cassandra.connection import Connection, ConnectionShutdown
-
+import sys
 import asyncio
 import logging
 import os
@@ -89,9 +89,11 @@ def __init__(self, *args, **kwargs):
 
         self._connect_socket()
         self._socket.setblocking(0)
-
-        self._write_queue = asyncio.Queue(loop=self._loop)
-        self._write_queue_lock = asyncio.Lock(loop=self._loop)
+        loop_args = dict()
+        if sys.version_info[0] == 3 and sys.version_info[1] < 10:
+            loop_args['loop'] = self._loop
+        self._write_queue = asyncio.Queue(**loop_args)
+        self._write_queue_lock = asyncio.Lock(**loop_args)
 
         # see initialize_reactor -- loop is running in a separate thread, so we
         # have to use a threadsafe call
@@ -174,7 +176,7 @@ def push(self, data):
 
     async def _push_msg(self, chunks):
         # This lock ensures all chunks of a message are sequential in the Queue
-        with await self._write_queue_lock:
+        async with self._write_queue_lock:
             for chunk in chunks:
                 self._write_queue.put_nowait(chunk)