Renamed StreamSink to EventSink. Renamed signalError to addError.

sdk/lib/io/string_transformer.dart

 // Copyright (c) 2013, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 part of dart.io;
 
 /**
  * String encodings.
  */
 class Encoding {
@@ skipping 149 matching lines @@
 }
 
 
 class LineTransformer extends StreamEventTransformer<String, String> {
   const int _LF = 10;
   const int _CR = 13;
 
   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;
     }
     int startPos = 0;
     int pos = 0;
     while (pos < data.length) {
       int skip = 0;
       int char = data.codeUnitAt(pos);
       if (char == _LF) {
@@ skipping 21 matching lines @@
     if (pos != startPos) {
       // Add remaining
       _buffer.write(data.substring(startPos, pos));
     }
     if (isClosing && !_buffer.isEmpty) {
       sink.add(_buffer.toString());
       _buffer = new StringBuffer();
     }
   }
 
-  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();
   }
 }
 
 
 abstract class _SingleByteDecoder
     extends StreamEventTransformer<List<int>, String> {
   final int _replacementChar;
 
   _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]);
       if (char < 0) char = _replacementChar;
       buffer[i] = char;
     }
     sink.add(new String.fromCharCodes(buffer));
   }
 
   int _decodeByte(int byte);
@@ skipping 13 matching lines @@
 // bytes.
 class _Latin1Decoder extends _SingleByteDecoder {
   _Latin1Decoder(int replacementChar) : super(replacementChar);
 
   int _decodeByte(int byte) => ((byte & 0xFF) == byte) ? byte : -1;
 }
 
 
 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();
     } else {
       sink.add(bytes);
     }
   }
 
   List<int> _encode(String string);
 }
@@ skipping 30 matching lines @@
 class _WindowsCodePageEncoder extends _SingleByteEncoder {
   List<int> _encode(String string) => _encodeString(string);
 
   external static List<int> _encodeString(String string);
 }
 
 
 // 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));
   }
 
   external static String _decodeBytes(List<int> bytes);
 }