Feeding an Effect Queue with an Async Generator

const readGzipFile = async function* (
  filePath: string,
): AsyncGenerator<string, void, unknown> {
  const fileStream = fs.createReadStream(filePath);
  const gunzip = zlib.createGunzip();
  const rl = readline.createInterface({
    input: fileStream.pipe(gunzip),
    crlfDelay: Infinity,
  });
  for await (const line of rl) yield line;
};