backpressure-fork.ts

const notifier = new Subject<any>();
const fork = pages<Repo>("https://api.github.com/users/cartant/starred", notifier).pipe(
  concatMap((repos, index) => concat(
    from(repos).pipe({
      concatMap(repo => ajax.post(forks_url)),
      ignoreElements()
    })),
    of(index)
  ),
  tap(notifier)
);
fork.subscribe({
  complete: () => console.log("forked")
});