diff --git a/dsmr_parser/clients/protocol.py b/dsmr_parser/clients/protocol.py index 73ad9d5..70be235 100644 --- a/dsmr_parser/clients/protocol.py +++ b/dsmr_parser/clients/protocol.py @@ -4,7 +4,7 @@ from functools import partial import asyncio import logging -from serial_asyncio import create_serial_connection +from serial_asyncio_fast import create_serial_connection from dsmr_parser import telegram_specifications from dsmr_parser.clients.telegram_buffer import TelegramBuffer diff --git a/dsmr_parser/clients/rfxtrx_protocol.py b/dsmr_parser/clients/rfxtrx_protocol.py index 848de71..0ebcafd 100644 --- a/dsmr_parser/clients/rfxtrx_protocol.py +++ b/dsmr_parser/clients/rfxtrx_protocol.py @@ -2,7 +2,7 @@ import asyncio -from serial_asyncio import create_serial_connection +from serial_asyncio_fast import create_serial_connection from .protocol import DSMRProtocol, _create_dsmr_protocol diff --git a/dsmr_parser/clients/serial_.py b/dsmr_parser/clients/serial_.py index 08b69d8..a084c53 100644 --- a/dsmr_parser/clients/serial_.py +++ b/dsmr_parser/clients/serial_.py @@ -1,6 +1,6 @@ import logging import serial -import serial_asyncio +import serial_asyncio_fast from dsmr_parser.clients.telegram_buffer import TelegramBuffer from dsmr_parser.exceptions import ParseError, InvalidChecksumError @@ -77,7 +77,7 @@ class AsyncSerialReader(SerialReader): :rtype: None """ # create Serial StreamReader - conn = serial_asyncio.open_serial_connection(**self.serial_settings) + conn = serial_asyncio_fast.open_serial_connection(**self.serial_settings) reader, _ = await conn while True: @@ -107,7 +107,7 @@ class AsyncSerialReader(SerialReader): """ # create Serial StreamReader - conn = serial_asyncio.open_serial_connection(**self.serial_settings) + conn = serial_asyncio_fast.open_serial_connection(**self.serial_settings) reader, _ = await conn while True: diff --git a/setup.py b/setup.py index ec93e45..631b3d6 100644 --- a/setup.py +++ b/setup.py @@ -11,7 +11,7 @@ setup( packages=find_packages(exclude=('test', 'test.*')), install_requires=[ 'pyserial>=3,<4', - 'pyserial-asyncio<1', + 'pyserial-asyncio-fast>=0.11', 'pytz', 'Tailer==0.4.1', 'dlms_cosem==21.3.2'