Skip to content

Commit

Permalink
Added support for consumer kwargs
Browse files Browse the repository at this point in the history
I have an app that uses consumer, but needs to pass in some kwargs
for consumption at consumer function call time.  This patch adds
kwargs support to consumer creation as well as passing those kwargs
at consumer callback time.
  • Loading branch information
hemna committed Dec 22, 2020
1 parent 097ba85 commit 63ce7e8
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions aprslib/inet.py
Original file line number Diff line number Diff line change
Expand Up @@ -157,7 +157,7 @@ def sendall(self, line):
self.close()
raise ConnectionError(str(exp))

def consumer(self, callback, blocking=True, immortal=False, raw=False):
def consumer(self, callback, blocking=True, immortal=False, raw=False, **kwargs):
"""
When a position sentence is received, it will be passed to the callback function
Expand All @@ -180,9 +180,9 @@ def consumer(self, callback, blocking=True, immortal=False, raw=False):
for line in self._socket_readlines(blocking):
if line[0:1] != b'#':
if raw:
callback(line)
callback(line, **kwargs)
else:
callback(self._parse(line))
callback(self._parse(line), **kwargs)
else:
self.logger.debug("Server: %s", line.decode('utf8'))
except ParseError as exp:
Expand Down

0 comments on commit 63ce7e8

Please sign in to comment.