Function wrapWithAsyncIterable

test/utils/async-iterators.js:3–10

(asyncIterable, indefinite = false)

'use strict'

async function * wrapWithAsyncIterable (asyncIterable, indefinite = false) {
  for await (const chunk of asyncIterable) {
    yield chunk
  }
  if (indefinite) {
    await new Promise(() => {})
  }
}

const STREAM = 'stream'
const ASYNC_ITERATOR = 'async-iterator'