Rework Timer interface.

sdk/lib/io/file_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 _FileInputStream extends _BaseDataInputStream implements InputStream {
   _FileInputStream(String name)
       : _data = const [],
         _position = 0,
@@ skipping 206 matching lines @@
       _closeCallbackScheduled = true;
     }
   }
 
   void set onNoPendingWrites(void callback()) {
     _onNoPendingWrites = callback;
     if ((_pendingOperations == null || _pendingOperations.length == 0) &&
         outstandingWrites == 0 &&
         !_streamMarkedClosed &&
         _onNoPendingWrites != null) {
-      new Timer(0, (t) {
+      Timer.run(() {
         if (_onNoPendingWrites != null) {
           _onNoPendingWrites();
         }
       });
     }
   }
 
   void set onClosed(void callback()) {
     _onClosed = callback;
   }
@@ skipping 199 matching lines @@
     throwIfError(result, "Cannot retrieve directory for file '$_name'");
     return new Directory(result);
   }
 
   Future<RandomAccessFile> open([FileMode mode = FileMode.READ]) {
     _ensureFileService();
     Completer<RandomAccessFile> completer = new Completer<RandomAccessFile>();
     if (mode != FileMode.READ &&
         mode != FileMode.WRITE &&
         mode != FileMode.APPEND) {
-      new Timer(0, (t) {
+      Timer.run(() {
         completer.completeError(new ArgumentError());
       });
       return completer.future;
     }
     List request = new List.fixedLength(3);
     request[0] = _OPEN_REQUEST;
     request[1] = _name;
     request[2] = mode._mode;  // Direct int value for serialization.
     return _fileService.call(request).then((response) {
       if (_isErrorResponse(response)) {
@@ skipping 200 matching lines @@
       var stream = openOutputStream(mode);
       stream.write(bytes);
       stream.close();
       stream.onClosed = () {
         completer.complete(this);
       };
       stream.onError = (e) {
         completer.completeError(e);
       };
     } catch (e) {
-      new Timer(0, (t) => completer.completeError(e));
+      Timer.run(() => completer.completeError(e));
       return completer.future;
     }
     return completer.future;
   }
 
   void writeAsBytesSync(List<int> bytes, [FileMode mode = FileMode.WRITE]) {
     RandomAccessFile opened = openSync(mode);
     opened.writeListSync(bytes, 0, bytes.length);
     opened.closeSync();
   }
 
   Future<File> writeAsString(String contents,
                              {FileMode mode: FileMode.WRITE,
                               Encoding encoding: Encoding.UTF_8}) {
     try {
       var data = _StringEncoders.encoder(encoding).encodeString(contents);
       return writeAsBytes(data, mode);
     } catch (e) {
       var completer = new Completer();
-      new Timer(0, (t) => completer.completeError(e));
+      Timer.run(() => completer.completeError(e));
       return completer.future;
     }
   }
 
   void writeAsStringSync(String contents,
                          {FileMode mode: FileMode.WRITE,
                           Encoding encoding: Encoding.UTF_8}) {
     var data = _StringEncoders.encoder(encoding).encodeString(contents);
     writeAsBytesSync(data, mode);
   }
@@ skipping 81 matching lines @@
     return result;
   }
 
   Future<List<int>> read(int bytes) {
     _ensureFileService();
     Completer<List<int>> completer = new Completer<List<int>>();
     if (bytes is !int) {
       // Complete asynchronously so the user has a chance to setup
       // handlers without getting exceptions when registering the
       // then handler.
-      new Timer(0, (t) {
+      Timer.run(() {
         completer.completeError(new FileIOException(
             "Invalid arguments to read for file '$_name'"));
       });
       return completer.future;
     };
     if (closed) return _completeWithClosedException(completer);
     List request = new List(3);
     request[0] = _READ_REQUEST;
     request[1] = _id;
     request[2] = bytes;
@@ skipping 16 matching lines @@
     return _read(_id, bytes);
   }
 
   Future<int> readList(List<int> buffer, int offset, int bytes) {
     _ensureFileService();
     Completer<int> completer = new Completer<int>();
     if (buffer is !List || offset is !int || bytes is !int) {
       // Complete asynchronously so the user has a chance to setup
       // handlers without getting exceptions when registering the
       // then handler.
-      new Timer(0, (t) {
+      Timer.run(() {
         completer.completeError(new FileIOException(
             "Invalid arguments to readList for file '$_name'"));
       });
       return completer.future;
     };
     if (closed) return _completeWithClosedException(completer);
     List request = new List.fixedLength(3);
     request[0] = _READ_LIST_REQUEST;
     request[1] = _id;
     request[2] = bytes;
@@ skipping 35 matching lines @@
     return result;
   }
 
   Future<RandomAccessFile> writeByte(int value) {
     _ensureFileService();
     Completer<RandomAccessFile> completer = new Completer<RandomAccessFile>();
     if (value is !int) {
       // Complete asynchronously so the user has a chance to setup
       // handlers without getting exceptions when registering the
       // then handler.
-      new Timer(0, (t) {
+      Timer.run(() {
           completer.completeError(new FileIOException(
               "Invalid argument to writeByte for file '$_name'"));
       });
       return completer.future;
     }
     if (closed) return _completeWithClosedException(completer);
     List request = new List.fixedLength(3);
     request[0] = _WRITE_BYTE_REQUEST;
     request[1] = _id;
     request[2] = value;
@@ skipping 22 matching lines @@
     return result;
   }
 
   Future<RandomAccessFile> writeList(List<int> buffer, int offset, int bytes) {
     _ensureFileService();
     Completer<RandomAccessFile> completer = new Completer<RandomAccessFile>();
     if (buffer is !List || offset is !int || bytes is !int) {
       // Complete asynchronously so the user has a chance to setup
       // handlers without getting exceptions when registering the
       // then handler.
-      new Timer(0, (t) {
+      Timer.run(() {
           completer.completeError(new FileIOException(
           "Invalid arguments to writeList for file '$_name'"));
       });
       return completer.future;
     }
     if (closed) return _completeWithClosedException(completer);
 
     _BufferAndOffset result;
     try {
       result = _ensureFastAndSerializableBuffer(buffer, offset, bytes);
     } catch (e) {
       // Complete asynchronously so the user has a chance to setup
       // handlers without getting exceptions when registering the
       // then handler.
-      new Timer(0, (t) => completer.completeError(e));
+      Timer.run(() => completer.completeError(e));
       return completer.future;
     }
 
     List request = new List.fixedLength(5);
     request[0] = _WRITE_LIST_REQUEST;
     request[1] = _id;
     request[2] = result.buffer;
     request[3] = result.offset;
     request[4] = bytes;
     return _fileService.call(request).then((response) {
@@ skipping 22 matching lines @@
     if (result is OSError) {
       throw new FileIOException("writeList failed for file '$_name'", result);
     }
     return result;
   }
 
   Future<RandomAccessFile> writeString(String string,
                                        [Encoding encoding = Encoding.UTF_8]) {
     if (encoding is! Encoding) {
       var completer = new Completer();
-      new Timer(0, (t) {
+      Timer.run(() {
         completer.completeError(new FileIOException(
             "Invalid encoding in writeString: $encoding"));
       });
       return completer.future;
     }
     var data = _StringEncoders.encoder(encoding).encodeString(string);
     return writeList(data, 0, data.length);
   }
 
   int writeStringSync(String string, [Encoding encoding = Encoding.UTF_8]) {
@@ skipping 149 matching lines @@
 
   bool get closed => _id == 0;
 
   void _checkNotClosed() {
     if (closed) {
       throw new FileIOException("File closed '$_name'");
     }
   }
 
   Future _completeWithClosedException(Completer completer) {
-    new Timer(0, (t) {
+    Timer.run(() {
       completer.completeError(
           new FileIOException("File closed '$_name'"));
     });
     return completer.future;
   }
 
   final String _name;
   int _id;
 
   SendPort _fileService;
 }