ios - 在 ReactiveCocoa 中订阅信号进行网络调用的正确替代方法是什么？

Question

我是 ReactiveCocoa 世界的新手，在阅读了 ReactiveCocoa 的最佳实践之后 here我知道我需要“避免显式订阅和处理”但是在所有关于网络和ReactiveCocoa的教程中我看到了相同的模式:create signal (make GET 或 POST 请求服务器，解析结果，sendNext, sendCompleted) -> subcsribeNext (do UI结果或其他东西)-> subscribeError。因此，正如我们所见，这里有一个明确的订阅，我认为这并不好。

是否有一些更正确和概念上更纯粹的方法来做这件常见的事情？ rac_liftSelector:withSignals: 或类似的东西？或者当我们处理网络调用和 AFNetworking 时，我们应该始终使用这种标准订阅模式？详细的解释将非常有帮助。

编辑:

在我的应用程序中，我主要有获取调用，其中一些是依赖调用，另一些是单一调用(绝大多数)，例如 login 或 fetchWhatever，或 随随便便。我用这样的相同模式构造的所有 API 调用(self - 是我的 API 管理器 NVMAPI 类，它是 AFHTTPSessionManager 子类):

    -(RACSignal*)loginUserWithEmail:(NSString *)email andPassword:(NSString *)password
     {
        __block NSURLSessionDataTask* task;
        return [[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        task = [self GET:kUserLoginEndpoint
          parameters:@{@"email": email, @"password": password}
             success:^(NSURLSessionDataTask *task, id responseObject) {
                     NVMUser* user = [[NVMUser alloc] initWithDictionary:responseObject[@"user"]];
                   [subscriber sendNext:user];
                   [subscriber sendCompleted];
             } failure:^(NSURLSessionDataTask *task, NSError *error) {
                 [subscriber sendError:error];
             }];
    return [RACDisposable disposableWithBlock:^{
        [task cancel];
    }];
       }] replayLazily];
        }

我不使用 MVVM 而是使用简单的 MVC。下面是我如何在 View Controller 中调用 API 和创建信号:

[SVProgressHUD showWithStatus:@"Processing..." maskType:SVProgressHUDMaskTypeBlack];
[[[NVMAPI api] loginUserWithEmail:self.emailTextField.text
                               andPassword:self.passwordTextField.text]    
 subscribeNext:^(id x) {
                [self.activeUser setupWithUser:x];
                [SVProgressHUD dismiss];
                [self performSegueWithIdentifier:kLoginSeque sender:self];
 } 
     error:^(NSError *error) {
             [SVProgressHUD dismiss];
             [self showAlertWithText:error.localizedDescription title:@"Error"];
 }];

我使用相同方式的所有信号，如:fetchComments、postStatus 等。如果我有依赖调用，我使用 flattenMap 。所以我很感兴趣——这是创建和使用信号的正确方法吗(简单的 subscribeNext)？或者这可以通过一些更正确和优雅的方式来实现？

编辑 2:

我看到的订阅的主要问题 - 我不知道如何使用它们实现 tableview 的分页。我有 fetchComment 加载分页评论的方法 - 每页包含 15 条评论。我不能为此使用 subcribeNext 和 RAC() 绑定(bind)，对吗？我如何管理这种模式？

Answer 1

网络调用并不特殊，您可以像编写任何其他信号一样编写发出网络请求的信号。