| Index: sdk/lib/io/string_transformer.dart
|
| diff --git a/sdk/lib/io/string_transformer.dart b/sdk/lib/io/string_transformer.dart
|
| index 2b02639f474f2cb64d2c5a5a75b346f43a20bbcf..89b3598da84df75ef9a6ba1b3f4d8474400cb156 100644
|
| --- a/sdk/lib/io/string_transformer.dart
|
| +++ b/sdk/lib/io/string_transformer.dart
|
| @@ -167,7 +167,7 @@ class LineTransformer extends StreamEventTransformer<String, String> {
|
| StringBuffer _buffer = new StringBuffer();
|
| String _carry;
|
|
|
| - void _handle(String data, StreamSink<String> sink, bool isClosing) {
|
| + void _handle(String data, EventSink<String> sink, bool isClosing) {
|
| if (_carry != null) {
|
| data = _carry.concat(data);
|
| _carry = null;
|
| @@ -209,11 +209,11 @@ class LineTransformer extends StreamEventTransformer<String, String> {
|
| }
|
| }
|
|
|
| - void handleData(String data, StreamSink<String> sink) {
|
| + void handleData(String data, EventSink<String> sink) {
|
| _handle(data, sink, false);
|
| }
|
|
|
| - void handleDone(StreamSink<String> sink) {
|
| + void handleDone(EventSink<String> sink) {
|
| _handle("", sink, true);
|
| sink.close();
|
| }
|
| @@ -226,7 +226,7 @@ abstract class _SingleByteDecoder
|
|
|
| _SingleByteDecoder(this._replacementChar);
|
|
|
| - void handleData(List<int> data, StreamSink<String> sink) {
|
| + void handleData(List<int> data, EventSink<String> sink) {
|
| var buffer = new List<int>(data.length);
|
| for (int i = 0; i < data.length; i++) {
|
| int char = _decodeByte(data[i]);
|
| @@ -260,10 +260,10 @@ class _Latin1Decoder extends _SingleByteDecoder {
|
|
|
| abstract class _SingleByteEncoder
|
| extends StreamEventTransformer<String, List<int>> {
|
| - void handleData(String data, StreamSink<List<int>> sink) {
|
| + void handleData(String data, EventSink<List<int>> sink) {
|
| var bytes = _encode(data);
|
| if (bytes == null) {
|
| - sink.signalError(
|
| + sink.addError(
|
| new AsyncError(
|
| new FormatException("Invalid character for encoding")));
|
| sink.close();
|
| @@ -314,7 +314,7 @@ class _WindowsCodePageEncoder extends _SingleByteEncoder {
|
| // Utility class for decoding Windows current code page data delivered
|
| // as a stream of bytes.
|
| class _WindowsCodePageDecoder extends StreamEventTransformer<List<int>, String> {
|
| - void handleData(List<int> data, StreamSink<String> sink) {
|
| + void handleData(List<int> data, EventSink<String> sink) {
|
| sink.add(_decodeBytes(data));
|
| }
|
|
|
|
|