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

Question

我是 ReactiveCocoa 世界的新手，在阅读了 ReactiveCocoa here 的最佳实践之后，我知道我需要 "avoid explicit subscriptions and disposal" 但在所有关于网络和 ReactiveCocoa 的教程中，我看到了相同的模式：创建信号 (向服务器发出GET 或POST 请求，解析结果，sendNext，sendCompleted) -> subcsribeNext（对结果进行 UI 操作或其他操作）-> subscribeError。所以我们看到这里有一个明确的订阅，我认为这不好。

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

编辑：

在我的应用程序中，我主要获取调用，其中一些是依赖的，而另一些是单一的（绝大多数），例如 login 或 fetchWhatever 或 postWhatever。我用这样的相同模式构造的所有 API 调用（self - 是我的 API manager 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。以下是我如何在视图控制器中进行 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 加载分页 cmets 的方法 - 每页包含 15 个 cmets。我既不能使用subcribeNext 也不能使用RAC() 绑定，对吧？我该如何管理这种模式？

Answer 1

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