mirror/iceshrimp
1
0
Fork 0
mirror of https://iceshrimp.dev/iceshrimp/iceshrimp synced 2024-11-28 14:58:09 +09:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: streamingテストおそい (#8912)

Browse Source
This commit is contained in:
MeiMei 2022-07-03 20:54:54 +09:00 committed by GitHub
parent ba9ded3c96
commit 1831a6a339
2 changed files with 471 additions and 830 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1295
packages/backend/test/streaming.ts
View File

File diff suppressed because it is too large Load Diff

6
packages/backend/test/utils.ts
View File

@ -186,7 +186,7 @@ export function connectStream(user: any, channel: string, listener: (message: Re
});
}
export const waitFire = async (user: any, channel: string, trgr: () => any, cond: (msg: Record<string, any>) => boolean) => {
export const waitFire = async (user: any, channel: string, trgr: () => any, cond: (msg: Record<string, any>) => boolean, params?: any) => {
return new Promise<boolean>(async (res, rej) => {
let timer: NodeJS.Timeout;
@ -198,7 +198,7 @@ export const waitFire = async (user: any, channel: string, trgr: () => any, cond
if (timer) clearTimeout(timer);
res(true);
}
});
}, params);
} catch (e) {
rej(e);
}
@ -208,7 +208,7 @@ export const waitFire = async (user: any, channel: string, trgr: () => any, cond
timer = setTimeout(() => {
ws.close();
res(false);
}, 5000);
}, 3000);
try {
await trgr();