Introduce class Sink<T>.

pkg/analysis_server/lib/src/channel.dart

 // Copyright (c) 2014, 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.
 
 library channel;
 
 import 'dart:async';
 import 'dart:convert';
 import 'dart:io';
 
@@ skipping 160 matching lines @@
 
 /**
  * Instances of [_JsonStreamDecoder] convert JSON strings to JSON maps
  */
 class _JsonStreamDecoder extends Converter<String, Map> {
 
   @override
   Map convert(String text) => JSON.decode(text);
 
   @override
-  ChunkedConversionSink startChunkedConversion(ChunkedConversionSink sink) =>
+  ChunkedConversionSink startChunkedConversion(Sink sink) =>
       new _ChannelChunkSink<String, Map>(this, sink);
 }
 
 /**
  * Instances of [_ResponseConverter] convert JSON maps to [Response]s.
  */
 class _ResponseConverter extends Converter<Map, Response> {
 
   @override
   Response convert(Map json) => new Response.fromJson(json);
 
   @override
-  ChunkedConversionSink startChunkedConversion(ChunkedConversionSink sink) =>
+  ChunkedConversionSink startChunkedConversion(Sink sink) =>
       new _ChannelChunkSink<Map, Response>(this, sink);
 }
 
 /**
  * Instances of [_NotificationConverter] convert JSON maps to [Notification]s.
  */
 class _NotificationConverter extends Converter<Map, Notification> {
 
   @override
   Notification convert(Map json) => new Notification.fromJson(json);
 
   @override
-  ChunkedConversionSink startChunkedConversion(ChunkedConversionSink sink) =>
+  ChunkedConversionSink startChunkedConversion(Sink sink) =>
       new _ChannelChunkSink<Map, Notification>(this, sink);
 }
 
 /**
- * A [_ChannelChunkSink] uses a [Convter] to translate chunks.
+ * A [_ChannelChunkSink] uses a [Converter] to translate chunks.
  */
 class _ChannelChunkSink<S, T> extends ChunkedConversionSink<S> {
   final Converter<S, T> _converter;
-  final ChunkedConversionSink _chunkedSink;
+  final Sink _sink;
 
-  _ChannelChunkSink(this._converter, this._chunkedSink);
+  _ChannelChunkSink(this._converter, this._sink);
 
   @override
   void add(S chunk) {
     var convertedChunk = _converter.convert(chunk);
     if (convertedChunk != null) {
-      _chunkedSink.add(convertedChunk);
+      _sink.add(convertedChunk);
     }
   }
 
   @override
-  void close() => _chunkedSink.close();
+  void close() => _sink.close();
 }