diff --git a/plugins/catalog-backend/src/service/response/write.ts b/plugins/catalog-backend/src/service/response/write.ts index 8fbd54d01c..628a1cb27c 100644 --- a/plugins/catalog-backend/src/service/response/write.ts +++ b/plugins/catalog-backend/src/service/response/write.ts @@ -129,6 +129,12 @@ export function createResponseDataWriter( }); return async data => { + if (drainPromise) { + throw new Error( + 'Attempted overlapping write while waiting for previous write to drain', + ); + } + if (res.write(data, 'utf8')) { return 'ok'; }