create_tcp_dsmr_reader accepts loop=None but always expects a loop. Fixes #36

Browse Source
This commit is contained in:
Rick van Hattem 2019-12-12 22:20:16 +01:00 committed by GitHub
parent b31bcd61fc
commit 7c9c59308e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
dsmr_parser/clients/protocol.py
View File

@ -49,12 +49,13 @@ def create_dsmr_reader(port, dsmr_version, telegram_callback, loop=None):
def create_tcp_dsmr_reader(host, port, dsmr_version, def create_tcp_dsmr_reader(host, port, dsmr_version,
telegram_callback, loop=None): telegram_callback, loop=None):
"""Creates a DSMR asyncio protocol coroutine using TCP connection.""" """Creates a DSMR asyncio protocol coroutine using TCP connection."""
if not loop:
loop = asyncio.get_event_loop()
protocol, _ = create_dsmr_protocol( protocol, _ = create_dsmr_protocol(
dsmr_version, telegram_callback, loop=None) dsmr_version, telegram_callback, loop=loop)
conn = loop.create_connection(protocol, host, port) conn = loop.create_connection(protocol, host, port)
return conn return conn
class DSMRProtocol(asyncio.Protocol): class DSMRProtocol(asyncio.Protocol):
"""Assemble and handle incoming data into complete DSM telegrams.""" """Assemble and handle incoming data into complete DSM telegrams."""