()
| 252 | } |
| 253 | |
| 254 | const getFinalResponse = async (): Promise<HandlerCallbackResult> => { |
| 255 | const response = ctx.response |
| 256 | if (!response) { |
| 257 | throwRouteHandlerError() |
| 258 | } |
| 259 | |
| 260 | if (!streamResponse) { |
| 261 | return response |
| 262 | } |
| 263 | |
| 264 | if (response === streamResponse.response) { |
| 265 | return streamResponse |
| 266 | } |
| 267 | |
| 268 | if ( |
| 269 | streamResponse.response.body !== null && |
| 270 | response.body === streamResponse.response.body |
| 271 | ) { |
| 272 | return { ...streamResponse, response } |
| 273 | } |
| 274 | |
| 275 | await disposeStreamResponse('middleware response replaced') |
| 276 | return response |
| 277 | } |
| 278 | |
| 279 | const next = async (nextCtx?: TODO): Promise<TODO> => { |
| 280 | // Merge context if provided using safeObjectMerge for prototype pollution prevention |
no test coverage detected