在特定信号出现之前缓冲信号

Question

我想知道是否可以累积在特定信号的nexts 之间发生的信号结果。类似于

[[[RACSignal
    combineLatest:@[signal1, signal2, signal3]]
    takeUntil:signal4]
    subscribeNext:^(id x) {
        // ...
    }];

但在第一个 signal4 的 next 之后没有完成。

我正在处理的场景是我有一个viewController1，它呈现viewController2。 viewController2 允许用户更改object，该object 会影响viewController1 中显示的数据。目前我在viewController2 上公开objectChangedSignal 并从viewController1 收听它。

但是，我想直接从viewController1 接收object 的更改，但前提是它触发了viewWillAppear 信号，并且只有在viewWillDisappear 或viewController1 之后发生更改。

希望有道理，谢谢。

Answer 1

缓冲值的一种方法是使用-[RACSignal collect]，它将它们收集到一个数组中，直到信号完成：

[[[RACSignal combineLatest:@[ s1, s2, s3 ]]
    collect]
    takeUntil:s4]

但是，您可能希望在最终信号上单独发送每个值，而不是值数组。您可以使用-[RACSignal flattenMap:] 将这些值变平为最终信号：

[[[[RACSignal combineLatest:@[ s1, s2, s3 ]]
    collect]
    takeUntil:s4]
    flattenMap:^(NSArray *collected) {

        return [[collected rac_sequence] signal];

    }]

由于您不希望在s4 之后完成您的信号，您可以在每次s4 发送一个值后使用-repeat 重新订阅。如果您不这样做，-takeUntil: 将导致您的信号在发生这种情况时完成。

[[[[[RACSignal combineLatest:@[ s1, s2, s3 ]]
    collect]
    takeUntil:s4]
    flattenMap:^(NSArray *collected) {

        return [[collected rac_sequence] signal];

    }]
    repeat]

请注意，如果任何组合信号是冷信号，重新订阅将导致它们的副作用发生更多次。因此，您可能必须通过多播（或组合信号）将它们转换为热信号：

RACMulticastConnection *mc = [[RACSignal combineLatest:@[ s1, s2, s3 ]] publish];
RACDisposable *d = [mc connect];
[[[mc.signal
    takeUntil:s4]
    flattenMap:^(NSArray *collected) {

        return [[collected rac_sequence] signal];

    }]
    repeat]

如果您的信号将无限存在，您可能需要明确取消订阅（通过处置 d）。

（注意，此代码未经测试。）