(auth: AuthDto, types: SyncRequestType[], reset?: boolean)
| 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([ |
no test coverage detected