1

我从几天开始学习reactive-cocoa，今天我在玩reactivecocoa（reactiveSwift）的flatten方法，我尝试执行文档Basic operator中为concat flattening给出的片段。这是片段：

let (lettersSignal, lettersObserver) = Signal<String, NoError>.pipe()
let (numbersSignal, numbersObserver) = Signal<String, NoError>.pipe()
let (signal, observer) = Signal<Signal<String, NoError>, NoError>.pipe()

signal.flatten(.concat).observeValues { print($0) }

observer.send(value: lettersSignal)
observer.send(value: numbersSignal)
observer.sendCompleted()

numbersObserver.send(value: "1")    // nothing printed
lettersObserver.send(value: "a")    // prints "a"
lettersObserver.send(value: "b")    // prints "b"
numbersObserver.send(value: "2")    // nothing printed
lettersObserver.send(value: "c")    // prints "c"
lettersObserver.sendCompleted()     // prints "1, 2"
numbersObserver.send(value: "3")    // prints "3"
numbersObserver.sendCompleted()

根据文档和交互式可视化图（RAC marbles - flatten(.concat) 可视化图，输出应该是这样的，

首先它应该打印字母流，即

甲，乙，丙

& 一旦 letterStream 完成，它应该打印出数字流，即

1、2、3

所以这个观察的最终输出应该是

[a、b、c、1、2、3]

但是，我看到的串联输出是，

[a, b, c, 3]

为什么会这样？为什么只打印 numberStream 的最新值？而不是在字母流完成后打印整个数字流值。

如果我误解了什么，请告诉我。干杯。

4

1 回答 1

4

正如ReactiveSwift 的 slack channel中提到的，这是预期的结果。

引用文档：

开始观察外部事件流。在前一个事件流完成之前，不会观察到每个后续事件流。

所以numbersSignal只会发送值，一旦lettersObserver完成。

于 2017-01-05T09:50:01.823 回答