Change dart:io to use Future for one-shot operations.

runtime/bin/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.
 
 
 class _Directory implements Directory {
   static final kCreateRequest = 0;
   static final kDeleteRequest = 1;
   static final kExistsRequest = 2;
   static final kCreateTempRequest = 3;
   static final kListRequest = 4;
 
   static final kSuccessResponse = 0;
   static final kIllegalArgumentResponse = 1;
   static final kOSErrorResponse = 2;
 
   _Directory(String this._path);
   _Directory.current() : _path = _current();
 
   static String _current() native "Directory_Current";
   static _createTemp(String template) native "Directory_CreateTemp";
   static int _exists(String path) native "Directory_Exists";
   static _create(String path) native "Directory_Create";
   static _delete(String path, bool recursive) native "Directory_Delete";
   static SendPort _newServicePort() native "Directory_NewServicePort";
 
-  void exists(void callback(bool exists)) {
+  Future<bool> exists() {
     _ensureDirectoryService();
+    Completer<bool> completer = new Completer<bool>();
     List request = new List(2);
     request[0] = kExistsRequest;
     request[1] = _path;
     _directoryService.call(request).then((response) {
       if (_isErrorResponse(response)) {
-        _handleErrorResponse(response, "Exists failed");
+        var e = _exceptionFromResponse(response, "Exists failed");
+        completer.completeException(e);
       } else {
-        callback(response == 1);
+        completer.complete(response == 1);
       }
     });
+    return completer.future;
   }
 
   bool existsSync() {
     if (_path is !String) {
       throw new IllegalArgumentException();
     }
     var result = _exists(_path);
     if (result is OSError) {
       throw new DirectoryIOException("Exists failed", _path, result);
     }
     return (result == 1);
   }
 
-  void create(void callback()) {
+  Future<Directory> create() {
     _ensureDirectoryService();
+    Completer<Directory> completer = new Completer<Directory>();
     List request = new List(2);
     request[0] = kCreateRequest;
     request[1] = _path;
     _directoryService.call(request).then((response) {
       if (_isErrorResponse(response)) {
-        _handleErrorResponse(response, "Creation failed");
+        var e = _exceptionFromResponse(response, "Creation failed");
+        completer.completeException(e);
       } else {
-        callback();
+        completer.complete(this);
       }
     });
+    return completer.future;
   }
 
   void createSync() {
     if (_path is !String) {
       throw new IllegalArgumentException();
     }
     var result = _create(_path);
     if (result is OSError) {
       throw new DirectoryIOException("Creation failed", _path, result);
     }
   }
 
-  void createTemp(void callback()) {
+  Future<Directory> createTemp() {
     _ensureDirectoryService();
+    Completer<Directory> completer = new Completer<Directory>();
     List request = new List(2);
     request[0] = kCreateTempRequest;
     request[1] = _path;
     _directoryService.call(request).then((response) {
       if (_isErrorResponse(response)) {
-        _handleErrorResponse(response, "Creation of temporary directory failed");
+        var e = _exceptionFromResponse(response,
+                                       "Creation of temporary directory failed");

[Søren Gjesse, 2012/05/10 11:24:45]

Long line.

[Mads Ager (google), 2012/05/10 12:42:38]

Done.

+        completer.completeException(e);
       } else {
-        _path = response;
-        callback();
+        completer.complete(new Directory(response));
       }
     });
+    return completer.future;
   }
 
   void createTempSync() {
     if (_path is !String) {
       throw new IllegalArgumentException();
     }
     var result = _createTemp(path);
     if (result is OSError) {
       throw new DirectoryIOException("Creation of temporary directory failed",
                                      _path,
                                      result);
     }
-    _path = result;
+    return new Directory(result);
   }
 
-  void _deleteHelper(bool recursive, String errorMsg, void callback()) {
+  Future<Directory> _deleteHelper(bool recursive, String errorMsg) {
     _ensureDirectoryService();
+    Completer<Directory> completer = new Completer<Directory>();
     List request = new List(3);
     request[0] = kDeleteRequest;
     request[1] = _path;
     request[2] = recursive;
     _directoryService.call(request).then((response) {
       if (_isErrorResponse(response)) {
-        _handleErrorResponse(response, errorMsg);
+        var e = _exceptionFromResponse(response, errorMsg);
+        completer.completeException(e);
       } else {
-        callback();
+        completer.complete(this);
       }
     });
+    return completer.future;
   }
 
-  void delete(void callback()) {
-    _deleteHelper(false, "Deletion failed", callback);
+  Future<Directory> delete() {
+    return _deleteHelper(false, "Deletion failed");
   }
 
-  void deleteRecursively(void callback()) {
-    _deleteHelper(true, "Deletion failed", callback);
+  Future<Directory> deleteRecursively() {
+    return _deleteHelper(true, "Deletion failed");
   }
 
   void deleteSync() {
     if (_path is !String) {
       throw new IllegalArgumentException();
     }
     var result = _delete(_path, false);
     if (result is OSError) {
       throw new DirectoryIOException("Deletion failed", _path, result);
     }
   }
 
   void deleteRecursivelySync() {
     if (_path is !String) {
       throw new IllegalArgumentException();
     }
     var result = _delete(_path, true);
     if (result is OSError) {
       throw new DirectoryIOException("Deletion failed", _path, result);
     }
   }
 
-  void list([bool recursive = false]) {
+  DirectoryLister list([bool recursive = false]) {
+    return new _DirectoryLister(_path, recursive);
+  }
+
+  String get path() { return _path; }
+
+  bool _isErrorResponse(response) {
+    return response is List && response[0] != _FileUtils.kSuccessResponse;
+  }
+
+  Exception _exceptionFromResponse(response, String message) {
+    assert(_isErrorResponse(response));
+    switch (response[_FileUtils.kErrorResponseErrorType]) {
+      case _FileUtils.kIllegalArgumentResponse:
+        return new IllegalArgumentException();
+      case _FileUtils.kOSErrorResponse:
+        var err = new OSError(response[_FileUtils.kOSErrorResponseMessage],
+                              response[_FileUtils.kOSErrorResponseErrorCode]);
+        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) {
     final int kListDirectory = 0;
     final int kListFile = 1;
     final int kListError = 2;
     final int kListDone = 3;
 
     final int kResponseType = 0;
     final int kResponsePath = 1;
     final int kResponseComplete = 1;
     final int kResponseError = 2;
 
     List request = new List(3);
-    request[0] = kListRequest;
-    request[1] = _path;
+    request[0] = _Directory.kListRequest;
+    request[1] = path;
     request[2] = 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.
-    _newServicePort().send(request, responsePort.toSendPort());
+    _Directory._newServicePort().send(request, responsePort.toSendPort());
     responsePort.receive((message, replyTo) {
       if (message is !List || message[kResponseType] is !int) {
         responsePort.close();
         _reportError(new DirectoryIOException("Internal error"));
         return;
       }
       switch (message[kResponseType]) {
         case kListDirectory:
           if (_onDir != null) _onDir(message[kResponsePath]);
           break;
@@ skipping 33 matching lines @@
   }
 
   void set onDone(void onDone(bool completed)) {
     _onDone = onDone;
   }
 
   void set onError(void onError(e)) {
     _onError = onError;
   }
 
-  String get path() { return _path; }
-
-  void _ensureDirectoryService() {
-    if (_directoryService == null) {
-      _directoryService = _newServicePort();
-    }
-  }
-
   void _reportError(e) {
     if (_onError != null) {
       _onError(e);
     } else {
       throw e;
     }
   }
 
-  bool _isErrorResponse(response) {
-    return response is List && response[0] != _FileUtils.kSuccessResponse;
-  }
-
-  void _handleErrorResponse(response, String message) {
-    assert(_isErrorResponse(response));
-    switch (response[_FileUtils.kErrorResponseErrorType]) {
-      case _FileUtils.kIllegalArgumentResponse:
-        _reportError(new IllegalArgumentException());
-        break;
-      case _FileUtils.kOSErrorResponse:
-        var err = new OSError(response[_FileUtils.kOSErrorResponseMessage],
-                              response[_FileUtils.kOSErrorResponseErrorCode]);
-        _reportError(new DirectoryIOException(message, _path, err));
-        break;
-      default:
-        _reportError(new Exception("Unknown error"));
-        break;
-    }
-  }
-
   Function _onDir;
   Function _onFile;
   Function _onDone;
   Function _onError;
-
-  String _path;
-  SendPort _directoryService;
 }