Как сделать автокоррекцию timer в RxJS?

Question

[Programep]

Здравствуйте! Подскажите, пожалуйста, как сделать автокоррекцию таймера в RxJS. Пробовал такой код, но он не меняет задержку таймера:

this.reloadGameInfo_latency = 10000;
this.reloadGameInfo$ = timer(0, this.reloadGameInfo_latency);
this.reloadGameInfo$.subscribe((response) => {
this.reloadGameInfo_latency += 10000;
});

Comments

[Антон Швец]

не очень понял зачем вы пытаетесь менять задержку уже сформированного и сработавшего таймера

[Programep]

Антон Швец, я хочу сдвигать следующий вызов таймера на N мс. Например задержка сети 20мс и нужно сдвигать следующих запуск таймера на это время. Пример того, что нужно JavaScript: цикличные таймеры с автокоррекцией
:

var start = new Date().getTime(),
    time = 0,
    elapsed = '0.0';

function instance()
{
    time += 100;

    elapsed = Math.floor(time / 100) / 10;
    if(Math.round(elapsed) == elapsed) { elapsed += '.0'; }

    document.title = elapsed;

    var diff = (new Date().getTime() - start) - time;
    window.setTimeout(instance, (100 - diff));
}

window.setTimeout(instance, 100);

[Антон Швец]

Programep, так где у вас создание нового обсервабл таймера, если вам нужен следующий таймер?

[Programep]

Антон Швец, поэтому я задал вопрос.) Вы сталкивались с этим, можете подсказать какой оператор использовать? Сегодня пробовал такое решение, но оно естественно не работает. Также нашел оператор expand, но пока не понял подойдет он для решения или нет.

import { Component, OnInit } from '@angular/core';
import { timer, pipe } from 'rxjs';
import { tap, takeWhile } from 'rxjs/operators';

@Component({
  selector: 'app-root',
  templateUrl: './app.component.html',
  styleUrls: ['./app.component.css']
})
export class AppComponent implements OnInit {
  title = 'test-timers';
  latency = 5000;
  time1onoff = true;
  timer1;
  time2onoff = false;
  timer2;

  ngOnInit(){
    console.log('init');
    this.timer1 = timer(0, this.latency).pipe(      
      takeWhile( val => this.time1onoff )
    ).subscribe((val) => {
      if (val == 10){        
        this.latency = this.latency * 2;
        this.time1onoff = false;
        this.time2onoff = true;
      }
      console.log(val)
    });
    this.timer2 = timer(0, this.latency).pipe(      
      takeWhile( val => this.time2onoff )
    ).subscribe((val) => {
      if (val == 10){
        this.latency = this.latency * 2;
        this.time1onoff = true;
        this.time2onoff = false;
      }
      console.log(val)
    });
  }
}

Answer 1

[p1plop]

Нельзя изменить таймер в уже созданном Observable, только создать новый и подписаться на него