(self, buffer)
| 161 | pass # we don't handle logs for node |
| 162 | |
| 163 | def write_stdin(self, buffer): |
| 164 | # because we use unbuffered IO for |
| 165 | # stdout, stdin.write is also unbuffered |
| 166 | # so might under-run on writes |
| 167 | while len(buffer) > 0 and self.process.poll() is None: |
| 168 | written = self.process.stdin.write(buffer) |
| 169 | if written == len(buffer): |
| 170 | break |
| 171 | elif written == 0: |
| 172 | # full buffer - wait |
| 173 | time.sleep(0.01) |
| 174 | else: |
| 175 | buffer = buffer[written:] |
| 176 | |
| 177 | def execute_js(self, code, wait_for_terminate=True): |
| 178 | self.write_stdin((code + "\n").encode("utf-8")) |
no test coverage detected