gen.ts

import {get} from "https"
import {once} from "events";

export async function stream(url) {
  const [inbound] = await once(get(url), 'response');

  async function* request(completed) {
    const raceList = await Promise.race([
      once(inbound, 'data'),
      completed,
    ]);

    const line = raceList[0];
    if (!line) {
      return { done: true };
    }

    yield line.toString();
    yield* request(completed);
  }

  return request(
    once(inbound, 'end'),
  );
}


stream("https://www.google.com/").then(o => o.next()).then(console.log).catch(console.error);