Function drainAndGetNext

test/development/basic/next-rs-api.test.ts:126–136

* Drains the stream until no value is available for 100ms, then returns the next value.

(stream: AsyncIterableIterator<T>)

 * Drains the stream until no value is available for 100ms, then returns the next value.
 */
async function drainAndGetNext<T>(stream: AsyncIterableIterator<T>) {
  while (true) {
    const next = stream.next()
    const result = await Promise.race([
      new Promise((r) => setTimeout(() => r({ next }), 100)),
      next.then(() => undefined),
    ])

    if (result) return result
  }
}

function pagesIndexCode(text, props = {}) {
  return `import props from "../lib/props.js";