我有两个流,Stream<A>
和Stream<B>
。我有一个类型C
的构造函数,需要一个A
和一个B
。如何将两个Stream
s合并为Stream<C>
?
您可以在StreamZip
中使用package:async
将两个流组合成一对对,然后从中创建C
对象。
import "package:async" show StreamZip;
...
Stream<C> createCs(Stream<A> as, Stream<B> bs) =>
new StreamZip([as, bs]).map((ab) => new C(ab[0], ab[1]));
import 'dart:async' show Stream;
import 'package:async/async.dart' show StreamGroup;
main() async {
var s1 = stream(10);
var s2 = stream(20);
var s3 = StreamGroup.merge([s1, s2]);
await for(int val in s3) {
print(val);
}
}
Stream<int> stream(int min) async* {
int i = min;
while(i < min + 10) {
yield i++;
}
}
另见http://news.dartlang.org/2016/03/unboxing-packages-async-part-2.html
版画
10
20
11
21
12
22
13
23
14
24
15
25
16
26
17
27
18
28
19
29
如果您需要在Stream<A>
或Stream<B>
发出事件并使用两个流中的最新值时做出反应,请使用combineLatest
。
Stream<C> merge(Stream<A> streamA, Stream<B> streamB) {
return streamA
.transform(combineLatest(streamB, (a, b) => new C(a, b)));
}