gistfile1.js

function filterWithAll(p$, ...others) {
  if (process.env.DEBUG && !p$) throw Error();
  else if (others.length === 0) {
    return this::withLatestFrom(p$)::filter(([, p]) => p)::map(([x]) => x);
  } else {
    return this::withLatestFrom(p$, ...others)
      ::filter(([, ...ps]) => ps.every(p => p))
      ::map(([x]) => x);
  }
}

function pauseableAll(pauser$, ...others) {
  if (process.env.DEBUG && !pauser$) throw Error();
  if (others.length === 0) {
    return pauser$::switchMap(paused => (paused ? Observable::never() : this));
  } else {
    return pauser$::combineLatest(...others)
      ::switchMap(states => (states.some(s => s) ? Observable.never() : this));
  }
}