(options)
| 4 | |
| 5 | class StreamRecorder extends stream.Writable { |
| 6 | constructor(options) { |
| 7 | options = options || {}; |
| 8 | super(options); |
| 9 | this.flushRecords(); |
| 10 | } |
| 11 | |
| 12 | _write(chunk, encoding, callback) { |
| 13 | const record = JSON.parse(chunk.toString()); |
nothing calls this directly
no test coverage detected