Index: packages/quiver/test/async/concat_test.dart |
diff --git a/packages/quiver/test/streams/concat_test.dart b/packages/quiver/test/async/concat_test.dart |
similarity index 90% |
rename from packages/quiver/test/streams/concat_test.dart |
rename to packages/quiver/test/async/concat_test.dart |
index 7c05b0cee791ceeb47e1309ab976bbe3f9b147fb..3b70bfd4e46c54b53ada7b0f6c5f7f27e286fa5a 100644 |
--- a/packages/quiver/test/streams/concat_test.dart |
+++ b/packages/quiver/test/async/concat_test.dart |
@@ -12,12 +12,12 @@ |
// See the License for the specific language governing permissions and |
// limitations under the License. |
-library quiver.streams.concat_test; |
+library quiver.async.concat_test; |
import 'dart:async'; |
import 'package:test/test.dart'; |
-import 'package:quiver/streams.dart'; |
+import 'package:quiver/async.dart'; |
main() { |
group('concat', () { |
@@ -68,15 +68,13 @@ main() { |
}); |
test('should forward pause, resume, and cancel to current stream', () { |
- var wasPaused = false, |
- wasResumed = false, |
- wasCanceled = false; |
+ var wasPaused = false, wasResumed = false, wasCanceled = false; |
var controller = new StreamController<String>( |
onPause: () => wasPaused = true, |
onResume: () => wasResumed = true, |
onCancel: () { |
- wasCanceled = true; |
- }); |
+ wasCanceled = true; |
+ }); |
var concatenated = concat([controller.stream]); |
var subscription = concatenated.listen(null); |
controller.add('a'); |
@@ -95,14 +93,13 @@ main() { |
}); |
test('should forward iteration error and stop', () { |
- var data = [], |
- errors = []; |
+ var data = [], errors = []; |
var badIteration = |
['e', 'this should not get thrown'].map((message) => throw message); |
- var concatenated = concat(badIteration); |
+ var concatenated = concat(badIteration as Iterable<Stream>); |
var completer = new Completer(); |
- concatenated |
- .listen(data.add, onError: errors.add, onDone: completer.complete); |
+ concatenated.listen(data.add, |
+ onError: errors.add, onDone: completer.complete); |
return completer.future.then((_) { |
expect(data, []); |
expect(errors, ['e']); |