(output_stream, write_callback)
| 754 | |
| 755 | |
| 756 | def pipe_output_to_http(output_stream, write_callback): |
| 757 | class OutputToHttpListener: |
| 758 | def on_next(self, output): |
| 759 | write_callback(wrap_to_server_event('output', output)) |
| 760 | |
| 761 | def on_close(self): |
| 762 | pass |
| 763 | |
| 764 | output_stream.subscribe(OutputToHttpListener()) |
| 765 | |
| 766 | |
| 767 | def intercept_stop_when_running_scripts(io_loop, execution_service): |
no test coverage detected