objective-c - 这个简单的 `-flattenMap` ReactiveCocoa 代码有什么问题？

Question

多次阅读 -flattenMap 上的自述文件后，我仍然无法弄清楚为什么这段代码没有按预期执行。我应该认为 block 内的代码会运行两次，但它根本没有受到影响。我错过了一些非常愚蠢的事情吗？ (我使用的是 v2.4.7)我还尝试在调用 -flattenMap 后发送值，以防它是订单。没有骰子。

RACSubject *test = [[RACSubject alloc] init];
[test sendNext:@1];
[test sendNext:@2];
[test sendCompleted];
[test flattenMap:^RACStream *(id value) {
  NSLog(@"here: %@", value);
  return [RACSignal return:@NO];
}];

Answer 1

有两件事:

顺序确实很重要，因为这是一个主题，所以将其更改为:

RACSubject *test = [[RACSubject alloc] init];
[test flattenMap:^RACStream *(id value) {
    NSLog(@"here: %@", value);
    return [RACSignal return:@NO];
}];
[test sendNext:@1];
[test sendNext:@2];
[test sendCompleted];

现在，您仍然看不到任何内容 - 因为您还没有订阅它。您只是创建了一个可以执行所有这些操作的信号，但它会延迟实际执行任何工作，直到您提出要求为止。

RACSubject *test = [[RACSubject alloc] init];
[[test flattenMap:^RACStream *(id value) {
    NSLog(@"here: %@", value);
    return [RACSignal return:@NO];
}] subscribeNext:^(id value) {
    NSLog(@"got a %@", value);
}];
[test sendNext:@1];
[test sendNext:@2];
[test sendCompleted];

现在，由于有一个订阅者实际上想了解值，因此这些 send 将酌情触发。

将来，请避免在 subscribe* 和 do* 系列方法的 block 之外的任何地方放置副作用(例如日志记录)。 flattenMap 和其他组合器希望是纯粹的，因此如果违反这一点，您会看到类似这样的意外行为。

您可能知道这一点，并且只是测试 flattenMap，但您的代码可以简化为此处的 map -- flattenMap + 返回 == map 。