Small update

Browse Source
This commit is contained in:
Ronald Pijnacker 2021-12-30 20:32:44 +01:00
parent c7ed4acb03
commit 188cac5287
2 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
dsmr_parser/clients/protocol.py
View File

@ -21,7 +21,7 @@ def create_dsmr_protocol(dsmr_version, telegram_callback, loop=None, **kwargs):
return protocol return protocol
def _create_dsmr_protocol(dsmr_version, telegram_callback, protocol loop=None, **kwargs): def _create_dsmr_protocol(dsmr_version, telegram_callback, protocol, loop=None, **kwargs):
"""Creates a DSMR asyncio protocol.""" """Creates a DSMR asyncio protocol."""
if dsmr_version == '2.2': if dsmr_version == '2.2':

4
dsmr_parser/clients/rfxtrx_protocol.py
View File

@ -1,15 +1,13 @@
"""Asyncio protocol implementation for handling telegrams over a RFXtrx connection .""" """Asyncio protocol implementation for handling telegrams over a RFXtrx connection ."""
from functools import partial
import asyncio import asyncio
from serial_asyncio import create_serial_connection from serial_asyncio import create_serial_connection
from .protocol import DSMRProtocol, _create_dsmr_protocol from .protocol import DSMRProtocol, _create_dsmr_protocol
def create_rfxtrx_dsmr_protocol(dsmr_version, telegram_callback, loop=None, **kwargs): def create_rfxtrx_dsmr_protocol(dsmr_version, telegram_callback, loop=None, **kwargs):
"""Creates a DSMR asyncio protocol.""" """Creates a RFXtrxDSMR asyncio protocol."""
protocol = _create_dsmr_protocol(dsmr_version, telegram_callback, protocol = _create_dsmr_protocol(dsmr_version, telegram_callback,
RFXtrxDSMRProtocol, loop, **kwargs) RFXtrxDSMRProtocol, loop, **kwargs)
return protocol return protocol