(self)
| 922 | self.child_conn, self.parent_conn = multiprocessing.Pipe() |
| 923 | |
| 924 | def run(self): |
| 925 | self.parent_conn.close() |
| 926 | for s in iter(self.child_conn.recv, None): |
| 927 | self.child_conn.send(s.upper()) |
| 928 | self.child_conn.close() |
| 929 | |
| 930 | def submit(self, s): |
| 931 | assert type(s) is str |