Merge 63ce7e8 into 097ba85

rossengeorgiev · Dec 22, 2020 · fcd0d9b · fcd0d9b
2 parents 097ba85 + 63ce7e8
commit fcd0d9b
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/aprslib/inet.py b/aprslib/inet.py
@@ -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
 
@@ -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: