Skip to content
This repository was archived by the owner on Feb 10, 2025. It is now read-only.

Commit 1745cd6

Browse files
committed
Merge branch 'master' into safe-nulls
2 parents c957991 + 37075a0 commit 1745cd6

File tree

4 files changed

+4
-4
lines changed

4 files changed

+4
-4
lines changed

lib/src/aggregate_sample.dart

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -136,7 +136,7 @@ extension AggregateSample<T> on Stream<T> {
136136
triggerSub!.pause();
137137
}
138138
if (cancels.isEmpty) return null;
139-
return Future.wait(cancels).then((_) => null);
139+
return cancels.wait.then((_) => null);
140140
};
141141
};
142142
return controller.stream;

lib/src/combine_latest.dart

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -131,7 +131,7 @@ extension CombineLatest<T> on Stream<T> {
131131
];
132132
sourceSubscription = null;
133133
otherSubscription = null;
134-
return Future.wait(cancels).then((_) => null);
134+
return cancels.wait.then((_) => null);
135135
};
136136
};
137137
return controller.stream;

lib/src/switch.dart

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,7 @@ extension SwitchLatest<T> on Stream<Stream<T>> {
126126
if (sub != null) sub.cancel(),
127127
];
128128
if (cancels.isEmpty) return null;
129-
return Future.wait(cancels).then(_ignore);
129+
return cancels.wait.then(_ignore);
130130
};
131131
};
132132
return controller.stream;

test/scan_test.dart

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,7 @@ void main() {
5959
const TypeMatcher<Future<void>>(),
6060
const TypeMatcher<Future<void>>()
6161
]);
62-
expect(await Future.wait(result), [1, 3]);
62+
expect(await result.wait, [1, 3]);
6363
});
6464

6565
test('does not call for subsequent values while waiting', () async {

0 commit comments

Comments
 (0)