MCPcopy
hub / github.com/immich-app/immich / syncStream

Method syncStream

server/test/medium.factory.ts:316–323  ·  view source on GitHub ↗
(auth: AuthDto, types: SyncRequestType[], reset?: boolean)

Source from the content-addressed store, hash-verified

314 }
315
316 async syncStream(auth: AuthDto, types: SyncRequestType[], reset?: boolean) {
317 const stream = mediumFactory.syncStream();
318 // Wait for 2ms to ensure all updates are available and account for setTimeout inaccuracy
319 await wait(2);
320 await this.sut.stream(auth, stream, { types, reset });
321
322 return stream.getResponse();
323 }
324
325 async assertSyncIsComplete(auth: AuthDto, types: SyncRequestType[]) {
326 await expect(this.syncStream(auth, types)).resolves.toEqual([

Calls 3

waitFunction · 0.90
getResponseMethod · 0.80
streamMethod · 0.45

Tested by

no test coverage detected