| 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);
|
| }
|
| }
|
|
|
|
|