| Index: tests/lib/async/stream_controller_test.dart
|
| diff --git a/tests/lib/async/stream_controller_test.dart b/tests/lib/async/stream_controller_test.dart
|
| index 57b99e3699b5395100e8584cbcf627adbe2c6e3c..ba535d748dd3854c83da5cf0a5e1e3b3da455cca 100644
|
| --- a/tests/lib/async/stream_controller_test.dart
|
| +++ b/tests/lib/async/stream_controller_test.dart
|
| @@ -93,10 +93,10 @@ testMultiController() {
|
| expectedEvents =
|
| new Events()..error("a")..add(42)..error("b")..add("foo")..close();
|
| actualEvents = new Events.capture(c.stream.transform(
|
| - new StreamTransformer.from(
|
| - onData: (v, s) { s.signalError(new AsyncError(v)); },
|
| - onError: (e, s) { s.add(e.error); },
|
| - onDone: (s) {
|
| + new StreamTransformer(
|
| + handleData: (v, s) { s.signalError(new AsyncError(v)); },
|
| + handleError: (e, s) { s.add(e.error); },
|
| + handleDone: (s) {
|
| s.add("foo");
|
| s.close();
|
| })));
|
| @@ -282,10 +282,10 @@ testSingleController() {
|
| expectedEvents =
|
| new Events()..error("a")..add(42)..error("b")..add("foo")..close();
|
| actualEvents = new Events.capture(c.stream.transform(
|
| - new StreamTransformer.from(
|
| - onData: (v, s) { s.signalError(new AsyncError(v)); },
|
| - onError: (e, s) { s.add(e.error); },
|
| - onDone: (s) {
|
| + new StreamTransformer(
|
| + handleData: (v, s) { s.signalError(new AsyncError(v)); },
|
| + handleError: (e, s) { s.add(e.error); },
|
| + handleDone: (s) {
|
| s.add("foo");
|
| s.close();
|
| })));
|
|
|