File tree Expand file tree Collapse file tree 1 file changed +8
-11
lines changed
fixtures/streams_ext/test Expand file tree Collapse file tree 1 file changed +8
-11
lines changed Original file line number Diff line number Diff line change @@ -70,16 +70,13 @@ void main() {
70
70
);
71
71
});
72
72
73
- test ('Combined Streams emits from all source streams' , () async {
74
- final events = await combinedStreams ().toList ();
75
-
76
- // Check that we received exactly 10 events
77
- expect (events.length, 10 );
78
-
79
- // Check that we have at least one 'Count:' and one 'Fibonacci:'
80
- expect (events.any ((s) => s.startsWith ('Count:' )), isTrue);
81
- expect (events.any ((s) => s.startsWith ('Fibonacci:' )), isTrue);
82
-
83
- // The stream should be done
73
+ test ('Combined Streams emits from all source streams' , () {
74
+ expect (
75
+ combinedStreams (),
76
+ emitsInAnyOrder ([
77
+ predicate ((String s) => s.startsWith ('Count:' )),
78
+ predicate ((String s) => s.startsWith ('Fibonacci:' )),
79
+ ]),
80
+ );
84
81
});
85
82
}
You can’t perform that action at this time.
0 commit comments