Index: tests/lib/async/stream_transformer_from_handlers_test.dart |
diff --git a/tests/lib/async/stream_transformer_from_handlers_test.dart b/tests/lib/async/stream_transformer_from_handlers_test.dart |
index d9e56b800996b6dc0607ed2b1ee6311a28c4dc13..cf54dc843d7b3e0da1f82c9285ed1f8da217b1f7 100644 |
--- a/tests/lib/async/stream_transformer_from_handlers_test.dart |
+++ b/tests/lib/async/stream_transformer_from_handlers_test.dart |
@@ -7,7 +7,6 @@ import 'package:async_helper/async_helper.dart'; |
import 'dart:async'; |
import 'event_helper.dart'; |
- |
get currentStackTrace { |
try { |
throw 0; |
@@ -41,27 +40,21 @@ main() { |
controller.close(); |
}); |
controller.stream |
- .transform( |
- new StreamTransformer<int, String>.fromHandlers( |
- handleData: (int data, EventSink<String> sink) { |
- sink.add(data.toString()); |
- }, |
- handleError: (e, st, EventSink<String> sink) { |
- sink.add(e.toString()); |
- sink.addError(e, st); |
- }, |
- handleDone: (EventSink<String> sink) { |
- sink.add("done"); |
- sink.close(); |
- })) |
- .listen((data) => events.add(data), |
- onError: (e, st) { |
- events.add(e); |
- events.add(st); |
- }, |
- onDone: () { |
- Expect.listEquals(["499", "42", 42, stackTrace, "done"], |
- events); |
- delayCycles(asyncEnd, 3); |
- }); |
+ .transform(new StreamTransformer<int, String>.fromHandlers( |
+ handleData: (int data, EventSink<String> sink) { |
+ sink.add(data.toString()); |
+ }, handleError: (e, st, EventSink<String> sink) { |
+ sink.add(e.toString()); |
+ sink.addError(e, st); |
+ }, handleDone: (EventSink<String> sink) { |
+ sink.add("done"); |
+ sink.close(); |
+ })) |
+ .listen((data) => events.add(data), onError: (e, st) { |
+ events.add(e); |
+ events.add(st); |
+ }, onDone: () { |
+ Expect.listEquals(["499", "42", 42, stackTrace, "done"], events); |
+ delayCycles(asyncEnd, 3); |
+ }); |
} |