backpressure-pages.ts

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

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