Index: sdk/lib/io/data_transformer.dart |
diff --git a/sdk/lib/io/data_transformer.dart b/sdk/lib/io/data_transformer.dart |
index 3daf351922a9f25f3cb323233440c558c6a44748..e75335bd49cb077cd80fe9ffa31439030b7fbd65 100644 |
--- a/sdk/lib/io/data_transformer.dart |
+++ b/sdk/lib/io/data_transformer.dart |
@@ -39,7 +39,7 @@ class _FilterTransformer extends StreamEventTransformer<List<int>, List<int>> { |
_FilterTransformer(_Filter this._filter); |
- void handleData(List<int> data, StreamSink<List<int>> sink) { |
+ void handleData(List<int> data, EventSink<List<int>> sink) { |
if (_closed) return; |
try { |
_filter.process(data); |
@@ -49,12 +49,12 @@ class _FilterTransformer extends StreamEventTransformer<List<int>, List<int>> { |
} |
} catch (e, s) { |
_closed = true; |
- sink.signalError(new AsyncError(e, s)); |
+ sink.addError(new AsyncError(e, s)); |
sink.close(); |
} |
} |
- void handleDone(StreamSink<List<int>> sink) { |
+ void handleDone(EventSink<List<int>> sink) { |
if (_closed) return; |
try { |
var out; |
@@ -62,7 +62,7 @@ class _FilterTransformer extends StreamEventTransformer<List<int>, List<int>> { |
sink.add(out); |
} |
} catch (e, s) { |
- sink.signalError(new AsyncError(e, s)); |
+ sink.addError(new AsyncError(e, s)); |
_closed = true; |
} |
if (!_closed) _filter.end(); |