fix: Update abort method in pipeWithDisconnect to return a promise for better error handling
This commit is contained in:
@@ -131,7 +131,7 @@ export function createDisconnectAwareStream(transformStream, streamController) {
|
|||||||
export function pipeWithDisconnect(providerResponse, transformStream, streamController) {
|
export function pipeWithDisconnect(providerResponse, transformStream, streamController) {
|
||||||
const transformedBody = providerResponse.body.pipeThrough(transformStream);
|
const transformedBody = providerResponse.body.pipeThrough(transformStream);
|
||||||
return createDisconnectAwareStream(
|
return createDisconnectAwareStream(
|
||||||
{ readable: transformedBody, writable: { getWriter: () => ({ abort: () => {} }) } },
|
{ readable: transformedBody, writable: { getWriter: () => ({ abort: () => Promise.resolve() }) } },
|
||||||
streamController
|
streamController
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user