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 fc6a3cf77ded110822715519ae642efb9f6a33c0..40c480c23bc27ef18e287389be2c2f48e6d96a3d 100644 |
--- a/tests/lib/async/stream_transform_test.dart |
+++ b/tests/lib/async/stream_transform_test.dart |
@@ -49,10 +49,11 @@ main() { |
test("closing after done", () { |
var controller = new StreamController(sync: true); |
- controller.stream.map((e) => e).transform(new StreamTransformer( |
- handleData: (element, sink) { sink.add(element); }, |
- handleDone: (sink) { sink.close(); }) |
- ).listen(expectAsync1((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(expectAsync1((e) => expect(e, equals("foo")))); |
controller.add("foo"); |
// Should not crash. |