| Index: packages/quiver/test/async/collect_test.dart
|
| diff --git a/packages/quiver/test/streams/collect_test.dart b/packages/quiver/test/async/collect_test.dart
|
| similarity index 91%
|
| rename from packages/quiver/test/streams/collect_test.dart
|
| rename to packages/quiver/test/async/collect_test.dart
|
| index a806fd86fe2624dcc0a86ffac93a035166555039..a2dc91f72bda826ad805f755952309078ee6b9ad 100644
|
| --- a/packages/quiver/test/streams/collect_test.dart
|
| +++ b/packages/quiver/test/async/collect_test.dart
|
| @@ -12,13 +12,13 @@
|
| // See the License for the specific language governing permissions and
|
| // limitations under the License.
|
|
|
| -library quiver.streams.collect_test;
|
| +library quiver.async.collect_test;
|
|
|
| import 'dart:async';
|
| import 'dart:math';
|
|
|
| import 'package:test/test.dart';
|
| -import 'package:quiver/streams.dart';
|
| +import 'package:quiver/async.dart';
|
|
|
| main() {
|
| group('collect', () {
|
| @@ -26,7 +26,7 @@ main() {
|
| () => collect([]).toList().then((events) => expect(events, isEmpty)));
|
|
|
| test('should produce events for future completions in input order', () {
|
| - var futures = new Iterable.generate(
|
| + var futures = new Iterable<Future>.generate(
|
| 5, (int i) => i.isEven ? new Future.value(i) : new Future.error(i));
|
| var events = [];
|
| var done = new Completer();
|
| @@ -39,7 +39,8 @@ main() {
|
| });
|
| });
|
|
|
| - test('should only advance iterator once '
|
| + test(
|
| + 'should only advance iterator once '
|
| 'event for previous future is sent', () {
|
| var eventCount = 0;
|
| var maxParallel = 0;
|
|
|