Renamed StreamSink to EventSink. Renamed signalError to addError.

pkg/http/lib/src/utils.dart

 // Copyright (c) 2012, 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 utils;
 
 import 'dart:async';
 import 'dart:crypto';
 import 'dart:io';
 import 'dart:scalarlist';
@@ skipping 134 matching lines @@
 /// place of [stream] after calling this method.
 Stream onDone(Stream stream, void onDone()) {
   var pair = tee(stream);
   pair.first.listen((_) {}, onError: (_) {}, onDone: onDone);
   return pair.last;
 }
 
 // TODO(nweiz): remove this when issue 7786 is fixed.
 /// Pipes all data and errors from [stream] into [sink]. When [stream] is done,
 /// [sink] is closed and the returned [Future] is completed.
-Future store(Stream stream, StreamSink sink) {
+Future store(Stream stream, EventSink sink) {
   var completer = new Completer();
   stream.listen(sink.add,
-      onError: sink.signalError,
+      onError: sink.addError,
       onDone: () {
         sink.close();
         completer.complete();
       });
   return completer.future;
 }
 
 /// Pipes all data and errors from [stream] into [sink]. Completes [Future] once
 /// [stream] is done. Unlike [store], [sink] remains open after [stream] is
 /// done.
-Future writeStreamToSink(Stream stream, StreamSink sink) {
+Future writeStreamToSink(Stream stream, EventSink sink) {
   var completer = new Completer();
   stream.listen(sink.add,
-      onError: sink.signalError,
+      onError: sink.addError,
       onDone: () => completer.complete());
   return completer.future;
 }
 
 /// Returns a [Future] that asynchronously completes to `null`.
 Future get async => new Future.immediate(null);
 
 /// Returns a closed [Stream] with no elements.
 Stream get emptyStream => streamFromIterable([]);
 
@@ skipping 10 matching lines @@
 /// Creates two single-subscription [Stream]s that each emit all values and
 /// errors from [stream]. This is useful if [stream] is single-subscription but
 /// multiple subscribers are necessary.
 Pair<Stream, Stream> tee(Stream stream) {
   var controller1 = new StreamController();
   var controller2 = new StreamController();
   stream.listen((value) {
     controller1.add(value);
     controller2.add(value);
   }, onError: (error) {
-    controller1.signalError(error);
-    controller2.signalError(error);
+    controller1.addError(error);
+    controller2.addError(error);
   }, onDone: () {
     controller1.close();
     controller2.close();
   });
   return new Pair<Stream, Stream>(controller1.stream, controller2.stream);
 }
 
 /// A pair of values.
 class Pair<E, F> {
   E first;
@@ skipping 28 matching lines @@
 /// The return values of all [Future]s are discarded. Any errors will cause the
 /// iteration to stop and will be piped through the return value.
 Future forEachFuture(Iterable input, Future fn(element)) {
   var iterator = input.iterator;
   Future nextElement(_) {
     if (!iterator.moveNext()) return new Future.immediate(null);
     return fn(iterator.current).then(nextElement);
   }
   return nextElement(null);
 }