Index: tests/lib/async/stream_transform_test.dart |
diff --git a/tests/lib/async/stream_transform_test.dart b/tests/lib/async/stream_transform_test.dart |
index 15e21d1169f24f6e23d71cda96d75eeb02d111b2..151c5043f989baecd0fadd8076060a0dfd90a192 100644 |
--- a/tests/lib/async/stream_transform_test.dart |
+++ b/tests/lib/async/stream_transform_test.dart |
@@ -9,14 +9,13 @@ import 'dart:async'; |
import 'package:unittest/unittest.dart'; |
import 'event_helper.dart'; |
- |
main() { |
// Regression tests for http://dartbug.com/8310 and 8311 |
test("simpleDone", () { |
StreamController c = new StreamController(sync: true); |
- Stream out = c.stream.handleError((x){}).handleError((x){}); |
- out.listen((v){}, onDone: expectAsync(() {})); |
+ Stream out = c.stream.handleError((x) {}).handleError((x) {}); |
+ out.listen((v) {}, onDone: expectAsync(() {})); |
// Should not throw. |
c.close(); |
}); |
@@ -49,11 +48,15 @@ main() { |
test("closing after done", () { |
var controller = new StreamController(sync: true); |
- controller.stream.map((e) => e) |
- .transform(new StreamTransformer.fromHandlers( |
- handleData: (element, sink) { sink.add(element); }, |
- handleDone: (sink) { sink.close(); })) |
- .listen(expectAsync((e) => expect(e, equals("foo")))); |
+ controller.stream |
+ .map((e) => e) |
+ .transform( |
+ new StreamTransformer.fromHandlers(handleData: (element, sink) { |
+ sink.add(element); |
+ }, handleDone: (sink) { |
+ sink.close(); |
+ })) |
+ .listen(expectAsync((e) => expect(e, equals("foo")))); |
controller.add("foo"); |
// Should not crash. |