Function flush

packages/sync-core/src/test/TLSyncRoom.test.ts:1111–1117

()

			socketPair.connect()

			const flush = async () => {
				await Promise.resolve()
				while (socketPair.getNeedsFlushing()) {
					socketPair.flushClientSentEvents()
					socketPair.flushServerSentEvents()
				}
			}
			let onSyncError = vi.fn()
			const client = await new Promise<TLSyncClient<Book | Presence>>((resolve, reject) => {
				onSyncError = vi.fn(reject)