convertAsyncIterable | /src/common/iterables/convertAsyncIterable.ts | fathym_common@v0.2.22-integration

function convertAsyncIterable

import { convertAsyncIterable } from "https://deno.land/x/fathym_common@v0.2.22-integration/src/common/iterables/convertAsyncIterable.ts";

convertAsyncIterable<T, R>(source: AsyncIterable<T>, converter: (item: T) => Promise<R>): AsyncIterable<R>

Convert an async iterable to an async iterable of another type.

Examples

From direct import

import { convertAsyncIterable } from '@fathym/common/iterables';

const asyncIterable = {
 [Symbol.asyncIterator]() {
   let i = 0;

   return {
     next() {
       if (i < 3) {
         return Promise.resolve(i);
       }

       return Promise.resolve(i);
     };
   }
 }
};

const ai = await convertAsyncIterable(asyncIterable, async (i) => i * 2);

console.log(Array.from(ai)); // [0, 2, 4, 6]

From common import

import { convertAsyncIterable } from '@fathym/common';

const ai = await convertAsyncIterable(asyncIterable, async (i) => i * 2);

console.log(Array.from(ai)); // [0, 2, 4, 6]

Type Parameters

Parameters

source: AsyncIterable<T>

The incoming iterable to convert

converter: (item: T) => Promise<R>

The method to use for converting the item.

Returns

AsyncIterable<R>

The async iterable of converted items.