actually commit the import change

Browse Source
This commit is contained in:
J. Nick Koston 2024-06-07 09:01:54 -05:00
parent 639b8d6264
commit d2edb52efd
No known key found for this signature in database
3 changed files with 5 additions and 5 deletions

2
dsmr_parser/clients/protocol.py
View File

@ -4,7 +4,7 @@ from functools import partial
import asyncio import asyncio
import logging 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 import telegram_specifications
from dsmr_parser.clients.telegram_buffer import TelegramBuffer from dsmr_parser.clients.telegram_buffer import TelegramBuffer

2
dsmr_parser/clients/rfxtrx_protocol.py
View File

@ -2,7 +2,7 @@
import asyncio import asyncio
from serial_asyncio import create_serial_connection from serial_asyncio_fast import create_serial_connection
from .protocol import DSMRProtocol, _create_dsmr_protocol from .protocol import DSMRProtocol, _create_dsmr_protocol

6
dsmr_parser/clients/serial_.py
View File

@ -1,6 +1,6 @@
import logging import logging
import serial import serial
import serial_asyncio import serial_asyncio_fast
from dsmr_parser.clients.telegram_buffer import TelegramBuffer from dsmr_parser.clients.telegram_buffer import TelegramBuffer
from dsmr_parser.exceptions import ParseError, InvalidChecksumError from dsmr_parser.exceptions import ParseError, InvalidChecksumError
@ -77,7 +77,7 @@ class AsyncSerialReader(SerialReader):
:rtype: None :rtype: None
""" """
# create Serial StreamReader # 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 reader, _ = await conn
while True: while True:
@ -107,7 +107,7 @@ class AsyncSerialReader(SerialReader):
""" """
# create Serial StreamReader # 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 reader, _ = await conn
while True: while True: