| 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.
|
|
|