Skip to content

Commit 8fe0f1d

Browse files
committed
fix: return headers in all serve handlers
1 parent e5e1e6c commit 8fe0f1d

File tree

3 files changed

+12
-0
lines changed

3 files changed

+12
-0
lines changed

platforms/express.ts

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -66,6 +66,11 @@ function createExpressHandler<TInitialPayload = unknown, TResult = unknown>(
6666
const response = await serveHandler(webRequest);
6767

6868
res.status(response.status).json(await response.json());
69+
70+
// set headers
71+
for (const [key, value] of response.headers.entries()) {
72+
res.setHeader(key, value);
73+
}
6974
};
7075
}
7176

platforms/nextjs.ts

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -106,6 +106,11 @@ export const servePagesRouter = <TInitialPayload = unknown, TResult = unknown>(
106106
});
107107
const response = await serveHandler(request);
108108
res.status(response.status).json(await response.json());
109+
110+
// set headers
111+
for (const [key, value] of response.headers.entries()) {
112+
res.setHeader(key, value);
113+
}
109114
};
110115

111116
return {

src/context/steps.ts

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -251,6 +251,8 @@ export class LazySleepStep extends BaseLazyStep {
251251
method: "POST",
252252
url: context.url,
253253
delay: isParallel ? undefined : this.sleep,
254+
retries: context.retries,
255+
flowControl: context.flowControl
254256
},
255257
])) as { messageId: string }[];
256258
}

0 commit comments

Comments
 (0)