我正在构建一个演示应用程序并试图符合 ReactiveCocoa design pattern越多越好。以下是该应用的作用:

• 找到设备的位置
• 每当位置键改变时，获取:
  • 当前天气
  • 每小时预报
  • 每日预报

所以顺序是 1) 更新位置 2) 合并所有 3 个天气数据。我构建了一个 WeatherManager 单例，它公开了天气对象、位置信息和手动更新的方法。此单例符合 CLLocationManagerDelegate 协议(protocol)。位置代码非常基本，所以我将其省略。唯一真正感兴趣的是:

- (void)locationManager:(CLLocationManager *)manager didUpdateLocations:(NSArray *)locations {
    // omitting accuracy & cache checking
    CLLocation *location = [locations lastObject];
    self.currentLocation = location;
    [self.locationManager stopUpdatingLocation];
}

获取天气状况非常相似，因此我构建了一个方法来生成 RACSignal 以从 URL 获取 JSON。

- (RACSignal *)fetchJSONFromURL:(NSURL *)url {
    return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        NSURLSessionDataTask *dataTask = [self.session dataTaskWithURL:url completionHandler:^(NSData *data, NSURLResponse *response, NSError *error) {
            if (! error) {
                NSError *jsonError = nil;
                id json = [NSJSONSerialization JSONObjectWithData:data options:kNilOptions error:&jsonError];
                if (! jsonError) {
                    [subscriber sendNext:json];
                }
                else {
                    [subscriber sendError:jsonError];
                }
            }
            else {
                [subscriber sendError:error];
            }

            [subscriber sendCompleted];
        }];

        [dataTask resume];

        return [RACDisposable disposableWithBlock:^{
            [dataTask cancel];
        }];
    }];
}

这有助于我保持我的方法简洁明了，所以现在我有 3 个简短的方法来构建 URL 并返回 RACSignal。这里的好处是我可以创建副作用来解析 JSON 并分配适当的属性(注意:我在这里使用 Mantle)。

- (RACSignal *)fetchCurrentConditions {
    // build URL
    return [[self fetchJSONFromURL:url] doNext:^(NSDictionary *json) {
        // simply converts JSON to a Mantle object
        self.currentCondition = [MTLJSONAdapter modelOfClass:[CurrentCondition class] fromJSONDictionary:json error:nil];
    }];
}

- (RACSignal *)fetchHourlyForecast {
    // build URL
    return [[self fetchJSONFromURL:url] doNext:^(NSDictionary *json) {
        // more work
    }];
}

- (RACSignal *)fetchDailyForecast {
    // build URL
    return [[self fetchJSONFromURL:url] doNext:^(NSDictionary *json) {
        // more work
    }];
}

最后，在我的单例的 -init 中，我在位置上设置了 RAC 观察器，因为每次位置改变时我都想获取和更新天气。

[[RACObserve(self, currentLocation)
 filter:^BOOL(CLLocation *newLocation) {
     return newLocation != nil;
 }] subscribeNext:^(CLLocation *newLocation) {
     [[RACSignal merge:@[[self fetchCurrentConditions], [self fetchDailyForecast], [self fetchHourlyForecast]]] subscribeError:^(NSError *error) {
         NSLog(@"%@",error.localizedDescription);
     }];
 }];

一切正常，但我担心我偏离了 Reactive 方式来构建我的获取和属性分配。我尝试使用 -then: 进行排序，但无法真正按照我的意愿进行设置。

我还试图找到一种干净的方法来将异步获取的结果绑定(bind)到我的单例的属性，但在实现它时遇到了麻烦。我无法弄清楚如何“扩展”获取的 RACSignal(注意:这就是每个 -doNext: 想法的来源)。

任何有助于解决这个问题的帮助或资源都会非常有用。谢谢!

最佳答案

-fetch 方法似乎不适合产生有意义的副作用，这让我认为您的 WeatherManager 类混淆了两个不同的东西:

1. 获取最新数据的网络请求
2. 该数据的有状态存储和呈现

这很重要，因为第一个问题是无状态的，而第二个问题几乎完全是有状态的。例如，在 GitHub for Mac 中，我们使用 OCTClient执行网络，然后将返回的用户数据存储在“持久状态管理器”单例中。

像这样分解后，我想它会更容易理解。您的状态管理器可以与网络客户端交互以启动请求，然后状态管理器可以订阅这些请求并应用副作用。

首先，让我们使 -fetch… 方法成为无状态的，方法是重写它们以使用转换而不是副作用:

- (RACSignal *)fetchCurrentConditions {
    // build URL
    return [[self fetchJSONFromURL:url] map:^(NSDictionary *json) {
        return [MTLJSONAdapter modelOfClass:[CurrentCondition class] fromJSONDictionary:json error:nil];
    }];
}

然后，您可以使用这些无状态方法并在更合适的地方向它们注入(inject)副作用:

- (RACSignal *)updateCurrentConditions {
    return [[self.networkClient
        // If this signal sends its result on a background thread, make sure
        // `currentCondition` is thread-safe, or make sure to deliver it to
        // a known thread.
        fetchCurrentConditions]
        doNext:^(CurrentCondition *condition) {
            self.currentCondition = condition;
        }];
}

并且，要更新所有这些，您可以使用 +merge:(就像在您的示例中一样)结合 -flattenMap: 将位置值映射到新的工作信号:

[[[RACObserve(self, currentLocation)
    ignore:nil]
    flattenMap:^(CLLocation *newLocation) {
        return [RACSignal merge:@[
            [self updateCurrentConditions],
            [self updateDailyForecast],
            [self updateHourlyForecast],
        ]];
    }]
    subscribeError:^(NSError *error) {
        NSLog(@"%@", error);
    }];

或者，要在 currentLocation 更改时自动取消正在进行的更新，请将 -flattenMap: 替换为 -switchToLatest:

[[[[RACObserve(self, currentLocation)
    ignore:nil]
    map:^(CLLocation *newLocation) {
        return [RACSignal merge:@[
            [self updateCurrentConditions],
            [self updateDailyForecast],
            [self updateHourlyForecast],
        ]];
    }]
    switchToLatest]
    subscribeError:^(NSError *error) {
        NSLog(@"%@", error);
    }];

(来自 ReactiveCocoa/ReactiveCocoa#786 的原始回复)。

关于ios - 具有异步网络请求的 ReactiveCocoa 排序，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/18705901/