Как выполнить это с ReactiveCocoa

Question

Я создаю функцию, где пользователи моего приложения могут найти своих друзей в Facebook и добавить их в приложение. Есть три шага, которые я должен сделать:

1. Получить подключенные в данный момент пользователь
2. Получить пользователь Facebook
3. Получить приложения Пользователей (это зависит от стадии 2)

После все эти полные мне тогда необходимо объединить/свести три результирующих массива в конечный массив.

Я создал три функции, которые все возвращают RACSignal

getUsersWithFacebookIds, getConnectedUsers и getFacebookUsers

Я не уверен, как подключить все это с помощью ReactiveCocoa.

Answer 1

Once All Are Done Do Something With All, можно достичь с помощью:

[[RACSignal combineLatest:@[connectUsersSignal,facebookUsersSignal,applicationUsersSignal]] subscribeNext:^(RACTuple *users) { 
    NSArray *connectedUsers = [users first]; 
    NSArray *facebookUsers = [users second]; 
    NSArray *applicationUsers = [users third]; 

}]; 

Другая часть отсутствует, как вы делаете applicationUsersSignal зависит от facbookUsersSignal. Что можно сделать следующим образом:

- (RACSignal *)applicationUsersSignalWithFacebookUsersSignal:(RACSignal *)fbSignal 
{ 
    return [fbSignal flattenMap:^RACStream *(NSArray *facebookUsers) { 
     return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) { 
      // Do what you have to do with the facebookUsers 
      return nil; 
     }]; 
    }]; 
} 

Просто добавьте немного больше ответа. Я предполагаю, что это холодные сигналы (сигналы, которые еще не начались, хотя и не были подписаны). Таким образом, идея использования combineLatest: заключается в том, что вы хотите захватить точку, в которой каждый отдельный сигнал отправляется как минимум один next, after that you subscribe to it so it can begin. Наконец, вы можете получить их значения от RACTuple.

---

Я снова прочитал ваш вопрос, и вы хотите, чтобы они пришли все в одном массиве:

[[[RACSignal combineLatest:@[connectUsersSignal,facebookUsersSignal,applicationUsersSignal]] map:^id(RACTuple *allArrays) { 
    return [allArrays.rac_sequence foldLeftWithStart:[NSMutableArray array] reduce:^id(id accumulator, id value) { 
     [accumulator addObjectsFromArray:value]; 
     return accumulator; 
    }]; 
}] subscribeNext:^(NSArray *allUsers) { 
    // Do Something 
}];