Show More
| @@ -116,6 +116,10 class OutStream(object): | |||||
| 116 | def close(self): |
|
116 | def close(self): | |
| 117 | self.pub_socket = None |
|
117 | self.pub_socket = None | |
| 118 |
|
118 | |||
|
|
119 | @property | |||
|
|
120 | def closed(self): | |||
|
|
121 | return self.pub_socket is None | |||
|
|
122 | ||||
| 119 | def _flush_from_subprocesses(self): |
|
123 | def _flush_from_subprocesses(self): | |
| 120 | """flush possible pub data from subprocesses into my buffer""" |
|
124 | """flush possible pub data from subprocesses into my buffer""" | |
| 121 | if not self._pipe_flag or not self._is_master_process(): |
|
125 | if not self._pipe_flag or not self._is_master_process(): | |
General Comments 0
You need to be logged in to leave comments.
Login now