##// END OF EJS Templates
allow subprocess output to trigger flush...
MinRK -
Show More
@@ -74,6 +74,13 b' 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