(fileName)
| 261 | } |
| 262 | |
| 263 | async processLogFile(fileName) { |
| 264 | this.collectEntries = true; |
| 265 | this.lastLogFileName_ = fileName; |
| 266 | let i = 1; |
| 267 | let line; |
| 268 | try { |
| 269 | while (line = readline()) { |
| 270 | await this.processLogLine(line); |
| 271 | i++; |
| 272 | } |
| 273 | } catch (e) { |
| 274 | console.error( |
| 275 | `Error occurred during parsing line ${i}` + |
| 276 | ', trying to continue: ' + e); |
| 277 | } |
| 278 | this.finalize(); |
| 279 | } |
| 280 | |
| 281 | async finalize() { |
| 282 | await this._chunkConsumer.consumeAll(); |
nothing calls this directly
no test coverage detected