Switch to pyserial-asyncio-fast to fix event loop being blocked (#34)

Author: bdraco

aioraven/serial.py

@@ -12,7 +12,7 @@
 from aioraven.streams import RAVEnStreamDevice
 from aioraven.streams import RAVEnWriter
 from serial import SerialException
-from serial_asyncio import create_serial_connection
+from serial_asyncio_fast import create_serial_connection
 
 
 async def open_serial_connection(
@@ -25,7 +25,7 @@ async def open_serial_connection(
     Establish a serial connection to a RAVEn device.
 
     Positional and keyword arguments are passed to
-    `serial_asyncio.create_serial_connection()`.
+    `serial_asyncio_fast.create_serial_connection()`.
 
     :param loop: The event loop instance to use.
     """
@@ -57,7 +57,7 @@ def __init__(
         Construct a RAVEnSerialDevice.
 
         Additional positional and keyword arguments are passed to
-        `serial_asyncio.create_serial_connection()`.
+        `serial_asyncio_fast.create_serial_connection()`.
 
         :param url: The pyserial URL of the device to connect to.
         :param loop: The event loop instance to use.

pyproject.toml

@@ -21,7 +21,7 @@ classifiers = [
 dependencies = [
     "iso4217",
     "pyserial>=2.5",
-    "pyserial-asyncio",
+    "pyserial-asyncio-fast",
 ]
 dynamic = ["version"]
 

test/mock_device.py

@@ -14,7 +14,7 @@
 from typing import TypeVar
 from typing import Union
 
-import serial_asyncio
+import serial_asyncio_fast
 
 
 _T = TypeVar('_T')
@@ -278,7 +278,7 @@ async def main(argv: list[str] = sys.argv) -> Optional[int]:
             sys.stdin.buffer, sys.stdout.buffer)
     elif len(argv) == 2:
         read_transport = None
-        reader, writer = await serial_asyncio.open_serial_connection(
+        reader, writer = await serial_asyncio_fast.open_serial_connection(
             url=argv[1])
     else:
         print(f'Usage: {argv[0]} [DEVICE_PATH]', file=sys.stderr)