diff options
author | Jesse Luehrs <doy@tozt.net> | 2014-09-15 00:56:06 -0400 |
---|---|---|
committer | Jesse Luehrs <doy@tozt.net> | 2014-09-15 00:56:06 -0400 |
commit | e820f9c4a7bcf887d77eb0df8946a59f32313e61 (patch) | |
tree | 9f3ae267dbb1caf3b20b09efe711992b2d6020f6 /termcast.py | |
parent | a306d46a1ee07504b56f8f1115b8693fdf7b92b5 (diff) | |
download | python-termcast-server-e820f9c4a7bcf887d77eb0df8946a59f32313e61.tar.gz python-termcast-server-e820f9c4a7bcf887d77eb0df8946a59f32313e61.zip |
actually broadcast the data being received
Diffstat (limited to 'termcast.py')
-rw-r--r-- | termcast.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/termcast.py b/termcast.py index fcc43c6..c1d8a5e 100644 --- a/termcast.py +++ b/termcast.py @@ -71,13 +71,13 @@ class Connection(object): while True: buf = self.client.recv(1024) if len(buf) > 0: + self.publisher.notify("new_data", self.connection_id, self.handler.buf, buf) self.handler.process(buf) else: return - def request_new_viewer(self, connection_id): + def msg_new_viewer(self, connection_id): # XXX restore this once we start passing in meaningful connection ids # if connection_id != self.connection_id: # return - term_contents = self.handler.get_term() - return term_contents.replace("\n", "\r\n") + self.publisher.notify("new_data", self.connection_id, self.handler.buf, b'') |