ReactiveCocoa - Подписаться на второй сигнал, если первый завершается без значения

Question

Представьте У меня есть два сигнала: дешевый и дорогой:

RACSignal *localSignal;  // Cheap signal. Sends object without network request 
          // if possible, otherwise completes immediately. 

RACSingal *networkSignal; // Expensive one. Always sends data, 
          // but requires expensive network operation. 

Теперь я хочу, чтобы создать сигнал, который посылает значение от первого сигнала, если таковой имеется, или подписаться на второй, и отправляет данные из этого.

Следующее решение почти дает мне то, что я хочу, но оно всегда соответствует второму дорогому сигналу, даже если принимается значение от первого сигнала, а значение второго сигнала игнорируется.

[[localDataSignal concat:networkDataSignal] take:1]; 

Есть ли способ решить проблему эффективно?

Answer 1

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

RACSignal *localSignal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) { 
    NSLog(@"Perfoming local operation"); 
    [subscriber sendNext:@"local value"]; 
    [subscriber sendCompleted]; 
    return nil; 
}]; 

Как я вижу проблемы (я не уверен на 100%) взять: 1 даже не было возможности распоряжаться каскадный сетевые сигналы. Но если я планирую локальный сигнал на отличном от планировщика основного потока, тогда возьмите: 1 работает как ожидалось - он разбивает цепочку после получения первого значения.

Простыми словами это фрагмент работы:

[[[localSignal deliverOn:[RACScheduler scheduler]] concat:networkSignal] take:1] 

Это дает мне именно то, что я хотел: значение местного сигнала, если таковой имеется, или присоединяется к сети сигнала и дает мне его значение. В случае, если локальный сигнал посылает значение, сетевой сигнал никогда не подписывается.

Правило большого пальца - это проверить поток, на который работает сигнал, а затем принять: 1 должен выполнить свою работу, как ожидалось.

Update: -deliveOnMainThread также дает -take: возможность распоряжаться очереди.

Answer 2

Вы можете использовать:

- (RACSignal *)catchTo:(RACSignal *)signal; 

Как это:

[[localSignal catchTo:networkSignal] subscribeNext:^(id x) { 
    // If localSignal sends error, networkSignal will be subscribed. 
}]; 

Answer 3

Это немного уродливое, но до сетевого сигнала конкатентный пустой сигнал с задержкой. Я не пробовал это, но он должен ввести асинхронность, необходимую для того, чтобы позволить take запретить подписку на networkSignal в случае, когда localSignal отправляет значение. Этот подход не влияет на доставку значения localSignal.

[[RACSignal concat:@[ 
    localSignal, 
    [[RACSignal empty] deliverOn:RACScheduler.mainThreadScheduler], 
    networkSignal 
] take:1] 

Альтернатива deliverOn:, вы могли бы рассмотреть delay:, если это делает проще этот код, чтобы понять.