import { mo } from 'moroutine';

export const sumStream = mo(import.meta, async (input: AsyncIterable<number>): Promise<number> => {
  let sum = 0;
  for await (const n of input) {
    sum += n;
  }
  return sum;
});

export const uppercaseStream = mo(import.meta, async function* (input: AsyncIterable<string>) {
  for await (const s of input) {
    yield s.toUpperCase();
  }
});