optimize: 优化请求处理程序,允许拦截器中异步发送请求。
parent
3650fb2e96
commit
aa04f998ca
|
@ -66,7 +66,7 @@ module.exports = function createRequestHandler (createIntercepts, middlewares, e
|
||||||
}
|
}
|
||||||
const goNext = reqIncpt.requestIntercept(context, req, res, ssl, next)
|
const goNext = reqIncpt.requestIntercept(context, req, res, ssl, next)
|
||||||
if (goNext) {
|
if (goNext) {
|
||||||
next()
|
if (goNext !== 'no-next') next()
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -215,7 +215,7 @@ module.exports = function createRequestHandler (createIntercepts, middlewares, e
|
||||||
(async () => {
|
(async () => {
|
||||||
await requestInterceptorPromise()
|
await requestInterceptorPromise()
|
||||||
|
|
||||||
if (res.writableEnded) {
|
if (res.writableEnded || res.waitingToWrite) {
|
||||||
// log.info('res is writableEnded, return false')
|
// log.info('res is writableEnded, return false')
|
||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue