1 | import { AsyncIterableX } from './asynciterablex';
|
2 | class DeferAsyncIterable extends AsyncIterableX {
|
3 | constructor(fn) {
|
4 | super();
|
5 | this._fn = fn;
|
6 | }
|
7 | async *[Symbol.asyncIterator]() {
|
8 | const items = await this._fn();
|
9 | for await (const item of items) {
|
10 | yield item;
|
11 | }
|
12 | }
|
13 | }
|
14 | export function defer(factory) {
|
15 | return new DeferAsyncIterable(factory);
|
16 | }
|
17 |
|
18 | //# sourceMappingURL=defer.mjs.map
|