-
- def __init__(self, socket, urwid_pipe_write_fd, server_output):
- super().__init__()
- self.socket = socket
- self.urwid_pipe = urwid_pipe_write_fd
- self.server_output = server_output
-
- def run(self):
- """On message receive, write to self.server_output, ping urwid pipe."""
- import os
- for msg in plom_socket_io.recv(self.socket):
- self.server_output[0] = msg
- os.write(self.urwid_pipe, b' ')
+ import os
+ for msg in plom_socket_io.recv(socket):
+ server_output[0] = msg
+ os.write(urwid_pipe_write_fd, b' ')