(chunk: Buffer)
| 124 | } |
| 125 | |
| 126 | process(chunk: Buffer): Promise<ProcessLineResult[]> { |
| 127 | return new Promise((resolve, reject) => { |
| 128 | // console.log("chunk", chunk.length); |
| 129 | this.next = resolve; |
| 130 | // this.appendReadBuf(chunk); |
| 131 | this.childProcess.stdin?.write(chunk, () => { |
| 132 | // console.log("chunk callback"); |
| 133 | this.flushResult(); |
| 134 | }); |
| 135 | }); |
| 136 | } |
| 137 | } |
| 138 | |
| 139 | export interface Message { |
no test coverage detected