Как сделать паузу и запуск intrerval в RxJS?

Спасибо! Только сделал немного по-другому (в вашем примере reloadGameInfo будет стоят до тех пор пока this.second_to_event не будет снова больше 0, но его останавливать не нужно было, а нужно останавливать stepTimer):

reloadGameInfo = interval(10000);
stepTimer = interval(1000);
second_to_event = 100;
this.reloadGameInfoSubscription = this.reloadGameInfo.subscribe(() => {      
      this.gameService.getInfoGame(this.current_game.auth_key)
        .subscribe((response: Game) => {          
          /* update game info */
        });
    });
    this.stepTimerSubscription = this.stepTimer
      .pipe(filter(() => this.current_game.current_seconds_for_step > 0))
      .subscribe(() => {
        if (--this.current_game.current_seconds_for_step == 0) {
          this.gameService.skipStep(this.current_game.auth_key).subscribe(
            (response: any) => {
              if (response.success) {
                this.current_game.current_seconds_for_step = this.current_game.default_seconds_for_step;
              }
            }
          );
        }
      });

Помогите, пожалуйста, разобраться еще в нескольких вопросах.
1. Скажите, пожалуйста, правильно ли я понимаю что pipe с RxJS 5.5 добавили
для возможности замены такого кода
of(1,2,3).map(x => x + 1).filter(x => x > 2);
на такой:

of(1,2,3).pipe(
  map(x => x + 1),
  filter(x => x > 2)
);

? Или это сделано для другого?
2. Я просмотрел статью Укрощение Змейки с помощью реактивных потоков - увидел там пример что можно объединять подписки с помощью оператора combineLatest. Получается мне нужно убрать .subscribe() у this.stepTimer, this.reloadGameInfo и объединить их с помощью combineLatest, или как вы говорили flatMap(он же mergeMap)? Но не пойму где тогда указать то, что сейчас делается внутри subscribe.
3. Как вы думаете, какой лучше оператор использовать mergeMap/flatMap или combineLatest для объединения stepTimer и reloadGameInfo? Из документации понял что разница между mergeMap/flatMap и combineLatest, в том что при combineLatest будет содержать последние данные из stepTimer И reloadGameInfo, а при mergeMap/flatMap будут данные либо из stepTimer, либо из reloadGameInfo.

Programep,
1. pipe для возможности импортировать операторы по отдельности как простые функции и добавлять свои операторы без манкипатчинга прототипа Observable. Раньше это был let
2. mergeMap сливает наш поток с потоком из другого обсервабла.
combineLatest делает новый поток, состоящий из массивов последних значений входящих потоков. И срабатывает каждый раз, когда приходит новое значение одного из составляющих.

Антон Швец, спасибо! Разобрался теперь как это работает. Подскажите, пожалуйста, а как можно объединить два interval в одну подписку, чтобы не делать unsubscribe на для каждого inverval? Пробовал через mergeMap, но получается создаются лишние interval.

Programep, interval это порождающий оператор, а не подписка.
Вы хотите это чтоль?

import { interval, merge } from 'rxjs';
merge(
  interval(300),
  interval(1000),
).subcribe(console.log)

Или объединять подписки?

const sub = new Subscription();
const s1 = interval(300).subcribe(console.log);
const s2 = interval(1000).subcribe(console.log);
sub.add(s1).add(s2)
setTimeout(() => sub.unsubscribe(), 10000);

Антон Швец, не совсем понял в чем разница двух решений. Как понимаю в первом варианте будет по сути одна подписка, а во втором две объединены в одну. По сути получается один и тот же результат. Сейчас у меня два таймера: 1-й таймер обновляет информацию от сервера, а 2-й таймер обновляет счетчик обратного отсчета времени. Посмотрев пример из статью Укрощение Змейки с помощью реактивных потоков , подумал может быть имеет смысл объединить потоки в какой-то один глобальный, чтобы при необходимости можно остановить только глобальный поток, а не писать unsubscribe для каждого потока. Сейчас у меня сделано так, может быть можно улучшить?

this.reloadGameInfoSubscription = this.reloadGameInfo$
      .pipe(
        mergeMap((x) => this.gameService.getInfoGame(this.current_game.auth_key)
          .pipe(
            map((game: Game) => {
              return { tick: x, game: game };
            })
          )
        )
      ).subscribe((response: { tick: number, game: Game }) => {
        /*
        логика обработки
        */
      });
    this.stepTimerSubscription = this.stepTimer$
      .pipe(
        filter(() => this.current_game.current_seconds_for_step > 0
          && this.field.start_word.length > 0
          && this.current_game.status_id == gameStatusCode.two_player_in_game),
      ).subscribe(() => {
        if (--this.current_game.current_seconds_for_step == 0) {
          this.gameService.skipStep(this.current_game.auth_key)
            .pipe(
              mergeMap((skipStepResponse) => this.gameService.getInfoGame(this.current_game.auth_key)
                .pipe(
                  map((game: Game) => {
                    return { skipStepResponse: skipStepResponse, game: game };
                  }))
              )
            )
            .subscribe(
              (response) => {
                if (response.skipStepResponse.success) {
                  this.current_game.current_seconds_for_step = this.current_game.default_seconds_for_step;
                  this.gameService.setInfoGame(response.game);
                }
              }
            );
        }
      });

И еще один вопрос, правильно ли я понимаю что filter фактически не делает никакую реальную паузу, а только не дает выполнится коду который написан в subscribe() в примере ниже:

this.stepTimer$
      .pipe(
        filter(() => this.current_game.current_seconds_for_step > 0
          && this.field.start_word.length > 0
          && this.current_game.status_id == gameStatusCode.two_player_in_game),
      ).subscribe();

Programep,

не совсем понял в чем разница двух решений.

ну как бы это абсолютно разные вещи. Создание нового потока путем слияния двух интервалов, и складирование подписок в одну для удобной отписки всех скопом.
Это не решения, я просто не понял что вы имеете в виду. Похоже вы путаете поток и подписку на него.

А filter это фильтр, фильтрует поток по условию, не понял какая тут может быть пауза.

Антон Швец,

Создание нового потока путем слияния двух интервалов, и складирование подписок в одну для удобной отписки всех скопом.

Но при слиянии потов ведь тоже будет одна подписка, только, как я понимаю, логику придется писать в одном subscribe вместо нескольких, как это работает сейчас.

А filter это фильтр, фильтрует поток по условию, не понял какая тут может быть пауза.

Изначально я хотел сделать что-то похожее на это:

if (need_start_timer){
timer_step.start();
} else {
timer_step.pause();
}