worldcone/cherrypick
2
0
Fork 0
Code Issues Pull requests 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 0076797b15
commit 034c5d792b
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
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) => { return new Promise<boolean>(async (res, rej) => {
let timer: NodeJS.Timeout; let timer: NodeJS.Timeout;
@ -198,7 +198,7 @@ export const waitFire = async (user: any, channel: string, trgr: () => any, cond
if (timer) clearTimeout(timer); if (timer) clearTimeout(timer);
res(true); res(true);
} }
}); }, params);
} catch (e) { } catch (e) {
rej(e); rej(e);
} }
@ -208,7 +208,7 @@ export const waitFire = async (user: any, channel: string, trgr: () => any, cond
timer = setTimeout(() => { timer = setTimeout(() => {
ws.close(); ws.close();
res(false); res(false);
}, 5000); }, 3000);
try { try {
await trgr(); await trgr();