Merge pull request #283 from FreddieAkeroyd/add_unsolicited_replies

Add support for sending unsolicited messages from a device

Author: mattclarke

src/lewis/adapters/stream.py

@@ -43,6 +43,7 @@ def __init__(self, sock, target, stream_server):
         self._buffer = []
 
         self._stream_server = stream_server
+        self._target.handler = self
 
         self._set_logging_context(target)
         self.log.info('Client connected from %s:%s', *sock.getpeername())
@@ -108,6 +109,10 @@ def found_terminator(self):
 
         self._send_reply(reply)
 
+    def unsolicited_reply(self, reply):
+        self.log.debug('Sending unsolicited reply %s', reply)
+        self.push(b(reply + self._target.out_terminator))
+
     def handle_close(self):
         self.log.info('Closing connection to client %s:%s', *self.socket.getpeername())
         self._stream_server.remove_handler(self)