Show More
@@ -116,6 +116,10 class OutStream(object): | |||
|
116 | 116 | def close(self): |
|
117 | 117 | self.pub_socket = None |
|
118 | 118 | |
|
119 | @property | |
|
120 | def closed(self): | |
|
121 | return self.pub_socket is None | |
|
122 | ||
|
119 | 123 | def _flush_from_subprocesses(self): |
|
120 | 124 | """flush possible pub data from subprocesses into my buffer""" |
|
121 | 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