| 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']);
|
|
|