Method
_processOnChangeRequest
(req: IncomingMessage, res: ServerResponse)
Source from the content-addressed store, hash-verified
| 395 | } |
| 396 | |
| 397 | _processOnChangeRequest(req: IncomingMessage, res: ServerResponse) { |
| 398 | const watchers = this._changeWatchers; |
| 399 | |
| 400 | watchers.push({ |
| 401 | req, |
| 402 | res, |
| 403 | }); |
| 404 | |
| 405 | req.on('close', () => { |
| 406 | for (let i = 0; i < watchers.length; i++) { |
| 407 | if (watchers[i] && watchers[i].req === req) { |
| 408 | watchers.splice(i, 1); |
| 409 | break; |
| 410 | } |
| 411 | } |
| 412 | }); |
| 413 | } |
| 414 | |
| 415 | _rangeRequestMiddleware( |
| 416 | req: IncomingMessage, |
Tested by
no test coverage detected