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; |