Function pipeAsync

Pipes an Iterable or AsyncIterable through the list of asynchronous operators, and returns AsyncIterableExt.

It applies automatic conversion when a synchronous iterable is passed in.

import {pipeAsync, delay} from 'iter-ops';

const i = pipeAsync([1, 2, 3], delay(1000));

(async function() {
  for await (const a of i) {
      console.log(a); // 1, 2, 3 (with 1s delay)
  }
})();
Copy

See

• pipe
• pipeSync
• toIterable
• toAsync