Рефакторинг в ReactiveCocoa

К сожалению, в приведенном вами примере кода есть пара проблем:

1. Блок, переданный -addSignalBlock:, возвращает пустой сигнал. Это должно быть предупреждающим флагом, так как почти никогда не возвращаются ненужные значения. В данном случае это означает, что блок выполняет свою работу синхронно. Чтобы избежать блокировки основного потока, вы должны создать сигнал, который работает асинхронно, и вернуть его.
2. -switchToLatest и -deliverOn: ничего не делают. Большинство операторов сигналов работают только тогда, когда на полученный сигнал подписана подписка. В этом случае он просто исчезает в эфире.

Мы можем решить обе эти проблемы сразу. -addSignalBlock: возвращает сигнал из сигналов, возвращенных в блоке. Если мы вернем что-то значимое, это можно будет обработать вне этого метода.

Прежде всего, это нужно добавить в начало:

@weakify(self);

Когда ниже используется @strongify(self), это предотвращает цикл сохранения. Это необходимо, потому что RACCommand живет столько же, сколько self.

Теперь создание внутренних сигналов:

RACSignal *requestSignals = [command addSignalBlock:^(id value) {
    return [RACSignal start:^(BOOL *success, NSError **err) {
        @strongify(self);

        NSArray *array = [self.ff getArrayFromUri:@"/States" error:err];
        *success = (array != nil);

        return array;
    }];
}];

Внутри блока это просто создает сигнал, который вызовет -getArrayFromUri:error: и вернет свои результаты или ошибку, если она произошла. +start: гарантирует, что работа будет происходить в фоновом режиме.

Из всего этого мы получаем requestSignals, который является сигналом тех созданных сигналов. Это может полностью заменить RACSubject, использовавшийся изначально:

RACSignal *arrays = [[[requestSignals
    map:^(RACSignal *request) {
        return [request catch:^(NSError *error) {
            NSLog(@"the error = %@", error);
            return [RACSignal empty];
        }];
    }]
    flatten]
    deliverOn:RACScheduler.mainThreadScheduler];

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

Затем мы выравниваем сигнал сигналов. В результате получается сигнал arrays, который проходит через значения всех внутренних сигналов. Вот почему мы должны были игнорировать ошибки — если бы какая-либо из них достигла этой точки, мы навсегда перестали бы получать все значения из внутренних сигналов.

Наконец, мы «поднимаем» селектор для вызова:

[self rac_liftSelector:@selector(performSegueWithIdentifier:sender:) withObjects:kSomeSegue, arrays];

Это будет повторно отправлять -performSegueWithIdentifier:sender: всякий раз, когда arrays отправляет новое значение (которое будет NSArray, возвращаемым из сети). Вы можете думать об этом как о вызове метода с течением времени. Это лучше, чем подписка, потому что это упрощает побочные эффекты и управление памятью.

По своему опыту работы с фреймворком я обнаружил, что очень мало причин использовать RACSubject напрямую, особенно для таких разовых сигналов, как этот. RACSubjects представляют собой изменяемые сигналы, которые в данном случае вам не нужны, и на самом деле могут увеличить сложность вашего кода. Для вас было бы гораздо лучше вернуть ванильный сигнал (через +[RACSignal createSignal:]) внутри этого командного блока, а затем получить код запроса, составляющий тело сигнала:

[[[command addSignalBlock:^RACSignal *(id value) {
    //
    return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        //Request code here
            return nil;
    }];
}]switchToLatest]deliverOn:[RACScheduler mainThreadScheduler]]; 

Или, что еще лучше, вы можете реорганизовать getArrayFromUri:error:, чтобы вернуть сигнал и избавиться от этого троичного оператора:

 [[[command addSignalBlock:^RACSignal *(id value) {
     return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        //...
        [[self getArrayFromUri:@"/States"]subscribeError:^(NSError *error) {
            [subscriber sendError:error];
        } completed:^{
            [subscriber sendNext:array];
        }];
            return nil;
        }];
  }]switchToLatest]deliverOn:RACScheduler.mainThreadScheduler];

Что касается проблемы подписки на следующей строке, то их можно считать побочными эффектами сигнала, поэтому мы можем сделать их явно таковыми с соответствующими вариантами do:, примененными к сигналу для команды:

    [[[command addSignalBlock:^RACSignal *(id value) {
        return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
            [[[[self getArrayFromUri:@"/States"]doError:^(NSError *error) {
                NSLog(@"the error = %@", error.localizedDescription);
                [subscriber sendError:err];
            }] doNext:^(NSArray *array) {
                [subscriber sendNext:array];
                [self performSegueWithIdentifier:kSomeSegue sender:array];
            }] subscribeCompleted:^{
                [subscriber sendCompleted];
            }];
            return [RACDisposable disposableWithBlock:^{
                 // Cleanup
            }];
        }];
    }]switchToLatest]deliverOn:[RACScheduler mainThreadScheduler]]; 

Наконец, поскольку команды работают не так, как сигналы, самые внешние операторы не будут оцениваться (спасибо, @jspahrsummers), поэтому их можно удалить.

[command addSignalBlock:^RACSignal *(id value) {
            return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
                [[[[self getArrayFromUri:@"/States"]doError:^(NSError *error) {
                    NSLog(@"the error = %@", error.localizedDescription);
                    [subscriber sendError:err];
                }] doNext:^(NSArray *array) {
                    [subscriber sendNext:array];
                    [self performSegueWithIdentifier:kSomeSegue sender:array];
                }] subscribeCompleted:^{
                    [subscriber sendCompleted];
                }];
                return [RACDisposable disposableWithBlock:^{
                     // Cleanup
                }];
            }];
        }];