| 22 | // consumer's resume() targets the old one, so the resumed body stalls forever. |
| 23 | // The proxy always forwards to the controller of the currently active connection. |
| 24 | class RetryController { |
| 25 | constructor () { |
| 26 | this.target = null |
| 27 | } |
| 28 | |
| 29 | pause () { this.target?.pause() } |
| 30 | resume () { this.target?.resume() } |
| 31 | abort (reason) { this.target?.abort(reason) } |
| 32 | get paused () { return this.target?.paused ?? false } |
| 33 | get aborted () { return this.target?.aborted ?? false } |
| 34 | get reason () { return this.target?.reason ?? null } |
| 35 | get rawHeaders () { return this.target?.rawHeaders ?? null } |
| 36 | get rawTrailers () { return this.target?.rawTrailers ?? null } |
| 37 | } |
| 38 | |
| 39 | class RetryHandler { |
| 40 | constructor (opts, { dispatch, handler }) { |
nothing calls this directly
no outgoing calls
no test coverage detected
searching dependent graphs…