(callback)
| 58 | } |
| 59 | // Implementation of `Transform._flush` |
| 60 | _flush(callback) { |
| 61 | if (this.state.stop === true) { |
| 62 | return; |
| 63 | } |
| 64 | const err = this.api.parse( |
| 65 | undefined, |
| 66 | true, |
| 67 | (record) => { |
| 68 | this.push(record); |
| 69 | }, |
| 70 | () => { |
| 71 | this.push(null); |
| 72 | this.on("end", this.destroy); |
| 73 | }, |
| 74 | ); |
| 75 | callback(err); |
| 76 | } |
| 77 | } |
| 78 | |
| 79 | const parse = function () { |
nothing calls this directly
no test coverage detected