RxJS 6 буфер с откровением в качестве закрытия Notifier

Question

Как мне реализовать мои Observables, чтобы получить следующее поведение в RxJS 6?

RxMarble диаграмма

Описание: я пытаюсь создать буфер [1] для входящих значений Observable[0], который буферизуется после времени debounce[2] того же Observable[0].

Это то, что у меня есть сейчас:

const Observable = rxjs.Observable;
const buffer = rxjs.operators.buffer;
const debounceTime = rxjs.operators.debounceTime;

const DEBOUNCE_TIME_SPAN = 2000;
let $observableObserver = null;

// Custom cold observable.
const $observable = Observable.create((observer) => {
  // Exposed observer
  $observableObserver = observer;
  // Manual entries
  observer.next(0);
});

// Debounce time observable (OK)
const $debouncedObservable = $observable
  .pipe(debounceTime(DEBOUNCE_TIME_SPAN));

// Buffered observable (THIS DOES NOT WORK)
const $bufferObservable = $debouncedObservable
  .pipe(buffer($observable));

// So this doesn't print something correct.
$bufferObservable.subscribe({
  next: v => console.log(v),
});