backpressure-pages-zip.ts

import { EMPTY, Observable, zip } from "rxjs";
import { expand, map } from "rxjs/operators";
import { get } from "./github";

function pages<T>(
  uri: string,
  notifier: Observable<any>
): Observable<T[]> {
  return get<T[]>(uri).pipe(
    expand(({ next }) => {
      if (next) {
        return zip(notifier, get(next)).pipe(
          map(([, response]) => response)
        );
      }
      return EMPTY;
    }),
    map(({ content }) => content)
  );
}