Merge IO v2 branch to bleeding edge

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 208 matching lines @@
     if (_path is !String || newPath is !String) {
       throw new ArgumentError();
     }
     var result = _rename(_path, newPath);
     if (result is OSError) {
       throw new DirectoryIOException("Rename failed", _path, result);
     }
     return new Directory(newPath);
   }
 
-  DirectoryLister list({bool recursive: false}) {
-    return new _DirectoryLister(_path, recursive);
-  }
-
-  List listSync({bool recursive: false}) {
-    if (_path is! String || recursive is! bool) {
-      throw new ArgumentError();
-    }
-    return _list(_path, recursive);
-  }
-
-  String get path => _path;
-
-  String toString() => "Directory: '$path'";
-
-  bool _isErrorResponse(response) {
-    return response is List && response[0] != _SUCCESS_RESPONSE;
-  }
-
-  _exceptionOrErrorFromResponse(response, String message) {
-    assert(_isErrorResponse(response));
-    switch (response[_ERROR_RESPONSE_ERROR_TYPE]) {
-      case _ILLEGAL_ARGUMENT_RESPONSE:
-        return new ArgumentError();
-      case _OSERROR_RESPONSE:
-        var err = new OSError(response[_OSERROR_RESPONSE_MESSAGE],
-                              response[_OSERROR_RESPONSE_ERROR_CODE]);
-        return new DirectoryIOException(message, _path, err);
-      default:
-        return new Exception("Unknown error");
-    }
-  }
-
-  void _ensureDirectoryService() {
-    if (_directoryService == null) {
-      _directoryService = _newServicePort();
-    }
-  }
-
-  final String _path;
-  SendPort _directoryService;
-}
-
-class _DirectoryLister implements DirectoryLister {
-  _DirectoryLister(String path, bool recursive) {
-    const int LIST_DIRECTORY = 0;
-    const int LIST_FILE = 1;
+  Stream<FileSystemEntity> list({bool recursive: false}) {
+    const int LIST_FILE = 0;
+    const int LIST_DIRECTORY = 1;
     const int LIST_ERROR = 2;
     const int LIST_DONE = 3;
 
-    final int RESPONSE_TYPE = 0;
-    final int RESPONSE_PATH = 1;
-    final int RESPONSE_COMPLETE = 1;
-    final int RESPONSE_ERROR = 2;
+    const int RESPONSE_TYPE = 0;
+    const int RESPONSE_PATH = 1;
+    const int RESPONSE_COMPLETE = 1;
+    const int RESPONSE_ERROR = 2;
 
-    List request = new List.fixedLength(3);
-    request[0] = _Directory.LIST_REQUEST;
-    request[1] = path;
-    request[2] = recursive;
+    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();
-        _reportError(new DirectoryIOException("Internal error"));
+        controller.signalError(new DirectoryIOException("Internal error"));
         return;
       }
       switch (message[RESPONSE_TYPE]) {
+        case LIST_FILE:
+          controller.add(new File(message[RESPONSE_PATH]));
+          break;
         case LIST_DIRECTORY:
-          if (_onDir != null) _onDir(message[RESPONSE_PATH]);
-          break;
-        case LIST_FILE:
-          if (_onFile != null) _onFile(message[RESPONSE_PATH]);
+          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) {
-            _reportError(new ArgumentError());
+            controller.signalError(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;
-            _reportError(new DirectoryIOException("Directory listing failed",
-                                                  errorPath,
-                                                  err));
+            controller.signalError(
+                new DirectoryIOException("Directory listing failed",
+                                         errorPath,
+                                         err));
           } else {
-            _reportError(new DirectoryIOException("Internal error"));
+            controller.signalError(new DirectoryIOException("Internal error"));
           }
           break;
         case LIST_DONE:
           responsePort.close();
-          if (_onDone != null) _onDone(message[RESPONSE_COMPLETE]);
+          controller.close();
           break;
       }
     });
+
+    return controller.stream;
   }
 
-  void set onDir(void onDir(String dir)) {
-    _onDir = onDir;
+  List listSync({bool recursive: false}) {
+    if (_path is! String || recursive is! bool) {
+      throw new ArgumentError();
+    }
+    return _list(_path, recursive);
   }
 
-  void set onFile(void onFile(String file)) {
-    _onFile = onFile;
+  String get path => _path;
+
+  String toString() => "Directory: '$path'";
+
+  bool _isErrorResponse(response) {
+    return response is List && response[0] != _SUCCESS_RESPONSE;
   }
 
-  void set onDone(void onDone(bool completed)) {
-    _onDone = onDone;
-  }
-
-  void set onError(void onError(e)) {
-    _onError = onError;
-  }
-
-  void _reportError(e) {
-    if (_onError != null) {
-      _onError(e);
-    } else {
-      throw e;
+  _exceptionOrErrorFromResponse(response, String message) {
+    assert(_isErrorResponse(response));
+    switch (response[_ERROR_RESPONSE_ERROR_TYPE]) {
+      case _ILLEGAL_ARGUMENT_RESPONSE:
+        return new ArgumentError();
+      case _OSERROR_RESPONSE:
+        var err = new OSError(response[_OSERROR_RESPONSE_MESSAGE],
+                              response[_OSERROR_RESPONSE_ERROR_CODE]);
+        return new DirectoryIOException(message, _path, err);
+      default:
+        return new Exception("Unknown error");
     }
   }
 
-  Function _onDir;
-  Function _onFile;
-  Function _onDone;
-  Function _onError;
+  void _ensureDirectoryService() {
+    if (_directoryService == null) {
+      _directoryService = _newServicePort();
+    }
+  }
+
+  final String _path;
+  SendPort _directoryService;
 }