Show More
@@ -74,6 +74,13 class OutStream(object): | |||||
74 | return |
|
74 | return | |
75 | self._pipe_poller = zmq.Poller() |
|
75 | self._pipe_poller = zmq.Poller() | |
76 | self._pipe_poller.register(self._pipe_in, zmq.POLLIN) |
|
76 | self._pipe_poller.register(self._pipe_in, zmq.POLLIN) | |
|
77 | if IOLoop.initialized(): | |||
|
78 | # subprocess flush should trigger flush | |||
|
79 | # if kernel is idle | |||
|
80 | IOLoop.instance().add_handler(self._pipe_in, | |||
|
81 | lambda s, event: self.flush(), | |||
|
82 | IOLoop.READ, | |||
|
83 | ) | |||
77 |
|
84 | |||
78 | def _setup_pipe_out(self): |
|
85 | def _setup_pipe_out(self): | |
79 | # must be new context after fork |
|
86 | # must be new context after fork |
General Comments 0
You need to be logged in to leave comments.
Login now