ObservableGame.ts

this._interval = Observable.interval(1000 / 20).timeInterval();
this._screen.realloc();

let state = 0;

const bufferInput = this._input.getStream().buffer(this._interval);
const frames: Observable<Frame> = this._interval.combineLatest(bufferInput).map((value) => {
  return {
    actions: value[1],
    time: value[0]
  };
});

frames.subscribe((frame) => {
  this._log.debug({frame}, 'frame tick');

  let next = false;
  let prev = false;

  for (const action of frame.actions) {
    switch (action.command) {
      case Command.BaseMenu:
        complete();
      // ...
    }
  }
}