| Index: tests/lib/async/stream_event_transform_test.dart
|
| diff --git a/tests/lib/async/stream_event_transform_test.dart b/tests/lib/async/stream_event_transform_test.dart
|
| index debc2c0c801173629de425064643757212b5eea4..1f79f99c063a84e33a00dc1e2a5f10187d6d20fd 100644
|
| --- a/tests/lib/async/stream_event_transform_test.dart
|
| +++ b/tests/lib/async/stream_event_transform_test.dart
|
| @@ -8,37 +8,37 @@ import 'dart:async';
|
| import '../../../pkg/unittest/lib/unittest.dart';
|
| import 'event_helper.dart';
|
|
|
| -void handleData(int data, StreamSink<int> sink) {
|
| - sink.signalError(new AsyncError("$data"));
|
| +void handleData(int data, EventSink<int> sink) {
|
| + sink.addError(new AsyncError("$data"));
|
| sink.add(data + 1);
|
| }
|
|
|
| -void handleError(AsyncError e, StreamSink<int> sink) {
|
| +void handleError(AsyncError e, EventSink<int> sink) {
|
| String value = e.error;
|
| int data = int.parse(value);
|
| sink.add(data);
|
| - sink.signalError(new AsyncError("${data + 1}"));
|
| + sink.addError(new AsyncError("${data + 1}"));
|
| }
|
|
|
| -void handleDone(StreamSink<int> sink) {
|
| +void handleDone(EventSink<int> sink) {
|
| sink.add(99);
|
| sink.close();
|
| }
|
|
|
| class EventTransformer extends StreamEventTransformer<int,int> {
|
| - void handleData(int data, StreamSink<int> sink) {
|
| - sink.signalError(new AsyncError("$data"));
|
| + void handleData(int data, EventSink<int> sink) {
|
| + sink.addError(new AsyncError("$data"));
|
| sink.add(data + 1);
|
| }
|
|
|
| - void handleError(AsyncError e, StreamSink<int> sink) {
|
| + void handleError(AsyncError e, EventSink<int> sink) {
|
| String value = e.error;
|
| int data = int.parse(value);
|
| sink.add(data);
|
| - sink.signalError(new AsyncError("${data + 1}"));
|
| + sink.addError(new AsyncError("${data + 1}"));
|
| }
|
|
|
| - void handleDone(StreamSink<int> sink) {
|
| + void handleDone(EventSink<int> sink) {
|
| sink.add(99);
|
| sink.close();
|
| }
|
|
|