mirror of
https://github.com/puppeteer/puppeteer
synced 2024-06-14 14:02:48 +00:00
ci: try to fix request timeouts (#11183)
This commit is contained in:
parent
0316863391
commit
57dc357e90
@ -66,6 +66,7 @@ export class TestServer {
|
||||
#csp = new Map<string, string>();
|
||||
#gzipRoutes = new Set<string>();
|
||||
#requestSubscribers = new Map<string, Subscriber>();
|
||||
#requests = new Set<ServerResponse>();
|
||||
|
||||
static async create(dirPath: string): Promise<TestServer> {
|
||||
let res!: (value: unknown) => void;
|
||||
@ -192,12 +193,20 @@ export class TestServer {
|
||||
subscriber.reject.call(undefined, error);
|
||||
}
|
||||
this.#requestSubscribers.clear();
|
||||
for (const request of this.#requests.values()) {
|
||||
if (!request.writableEnded) {
|
||||
request.end();
|
||||
}
|
||||
}
|
||||
this.#requests.clear();
|
||||
}
|
||||
|
||||
#onRequest: RequestListener = (
|
||||
request: TestIncomingMessage,
|
||||
response
|
||||
): void => {
|
||||
this.#requests.add(response);
|
||||
|
||||
request.on('error', (error: {code: string}) => {
|
||||
if (error.code === 'ECONNRESET') {
|
||||
response.end();
|
||||
|
Loading…
Reference in New Issue
Block a user