Index: tests/lib/async/first_regression_test.dart |
diff --git a/tests/lib/async/first_regression_test.dart b/tests/lib/async/first_regression_test.dart |
index a8a512d750cb7757adccd6e27e7aab32c5f713f5..69e18ede87e65adf150ddd36c0388c779c1615b2 100644 |
--- a/tests/lib/async/first_regression_test.dart |
+++ b/tests/lib/async/first_regression_test.dart |
@@ -8,10 +8,14 @@ library first_regression_test; |
import 'dart:async'; |
import '../../../pkg/unittest/lib/unittest.dart'; |
-class DoubleTransformer<T> extends StreamEventTransformer<T, T> { |
- void handleData(T data, EventSink<T> sink) { |
- sink.add(data); |
- sink.add(data); |
+class DoubleTransformer<T> implements StreamTransformer<T, T> { |
+ Stream<T> bind(Stream<T> stream) { |
+ var transformer = new StreamTransformer<T, T>.fromHandlers( |
+ handleData: (T data, EventSink<T> sink) { |
+ sink.add(data); |
+ sink.add(data); |
+ }); |
+ return transformer.bind(stream); |
} |
} |