Каков наилучший способ сброса сигнала таймера?

Question

Мне нужно получать данные с сервера каждые 5 минут. Если я вытащил обновление, также нужно получить данные с сервера, а сбросить таймер.

Ниже код - это решение сейчас, отлично работает. Просто интересно, как упростить код? Вероятно, есть лучший способ в ReactiveCocoa?

RACSignal* refreshSignal = [self.refreshControl rac_signalForControlEvents:UIControlEventValueChanged]; 
    self.timerSignal = [[RACSignal interval:300 onScheduler:[RACScheduler scheduler] withLeeway:2] takeUntil:refreshSignal]; 
    [self.timerSignal subscribeNext:^(id x) { 
     NSLog(@"=========================="); 
     NSLog(@"[Timer1]"); 
     [self.viewModel performFetch]; 
    }]; 

    [refreshSignal subscribeNext:^(id x) { 
     NSLog(@"=========================="); 
     NSLog(@"[Refresh]"); 
     [self.viewModel performFetch]; 
     self.timerSignal = [[RACSignal interval:300 onScheduler:[RACScheduler scheduler] withLeeway:2] takeUntil:refreshSignal]; 
     [self.timerSignal subscribeNext:^(id x) { 
      NSLog(@"=========================="); 
      NSLog(@"[Timer2]"); 
      [self.viewModel performFetch]; 
     }]; 
    }]; 

Answer 1

Чистейшая способ, которым я могу думать, было бы с помощью RACReplaySubject, посылая сигналы interval 300, а затем переход к последнему сигнала, посланного каждый раз, когда блок увольняют.

self.timerSubject = [RACReplaySubject replaySubjectWithCapacity:1]; 
RACSignal * refreshSignal = [self.refreshControl rac_signalForControlEvents:UIControlEventValueChanged]; 
RACSignal * timeSignal = [RACSignal interval:300 onScheduler:[RACScheduler scheduler] withLeeway:2]; 
[self.timerSubject sendNext:timeSignal]; 

@weakify(self) 
[[self.timerSubject.switchToLatest merge:refreshSignal] subscribeNext:^(id _) { 
    @strongify(self) 
    [self.viewModel performFetch]; 
}]; 

[refreshSignal subscribeNext:^(id _) { 
    @strongify(self) 
    [self.timerSubject sendNext:timeSignal]; 
}]; 

Answer 2

Я бы обозначил refreshSignal для сигнала таймера. Каждый раз, когда refreshSignal отправляет значение, он отображается на сигнал, отправляющий значение каждые пять минут.

В качестве побочного примечания я считаю, что эта логика принадлежит модели представления. Там результирующий сигнал можно сопоставить с сетевым запросом с flatMap:. Затем текущий сетевой запрос будет отменен, если пользователь быстро обновится.

[[[[refreshSignal startWith:nil] 
map:^id(id value) { 
    return [[RACSignal interval:5 * 60 onScheduler:[RACScheduler mainThreadScheduler]] startWith:nil]; 
}] 
switchToLatest] 
subscribeNext:^(id x) { 
    @strongify(self) 
    [self.viewModel performFetch]; 
}];