Renamed StreamSink to EventSink. Renamed signalError to addError.

sdk/lib/io/directory_impl.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.
 
 part of dart.io;
 
 class _Directory implements Directory {
   static const CREATE_REQUEST = 0;
   static const DELETE_REQUEST = 1;
   static const EXISTS_REQUEST = 2;
@@ skipping 229 matching lines @@
     var controller = new StreamController<FileSystemEntity>();
 
     List request = [ _Directory.LIST_REQUEST, path, recursive ];
     ReceivePort responsePort = new ReceivePort();
     // Use a separate directory service port for each listing as
     // listing operations on the same directory can run in parallel.
     _Directory._newServicePort().send(request, responsePort.toSendPort());
     responsePort.receive((message, replyTo) {
       if (message is !List || message[RESPONSE_TYPE] is !int) {
         responsePort.close();
-        controller.signalError(new DirectoryIOException("Internal error"));
+        controller.addError(new DirectoryIOException("Internal error"));
         return;
       }
       switch (message[RESPONSE_TYPE]) {
         case LIST_FILE:
           controller.add(new File(message[RESPONSE_PATH]));
           break;
         case LIST_DIRECTORY:
           controller.add(new Directory(message[RESPONSE_PATH]));
           break;
         case LIST_ERROR:
           var errorType =
               message[RESPONSE_ERROR][_ERROR_RESPONSE_ERROR_TYPE];
           if (errorType == _ILLEGAL_ARGUMENT_RESPONSE) {
-            controller.signalError(new ArgumentError());
+            controller.addError(new ArgumentError());
           } else if (errorType == _OSERROR_RESPONSE) {
             var responseError = message[RESPONSE_ERROR];
             var err = new OSError(
                 responseError[_OSERROR_RESPONSE_MESSAGE],
                 responseError[_OSERROR_RESPONSE_ERROR_CODE]);
             var errorPath = message[RESPONSE_PATH];
             if (errorPath == null) errorPath = path;
-            controller.signalError(
+            controller.addError(
                 new DirectoryIOException("Directory listing failed",
                                          errorPath,
                                          err));
           } else {
-            controller.signalError(new DirectoryIOException("Internal error"));
+            controller.addError(new DirectoryIOException("Internal error"));
           }
           break;
         case LIST_DONE:
           responsePort.close();
           controller.close();
           break;
       }
     });
 
     return controller.stream;
@@ skipping 30 matching lines @@
 
   void _ensureDirectoryService() {
     if (_directoryService == null) {
       _directoryService = _newServicePort();
     }
   }
 
   final String _path;
   SendPort _directoryService;
 }