Remove .writeStream, .consume and rewrite IOSink to correctly implement a (sane) well-defined behav…

sdk/lib/async/timer.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.async;
 
 abstract class Timer {
   // Internal list used to group Timer.run callbacks.
   static List _runCallbacks = [];
 
@@ skipping 28 matching lines @@
    * The [callback] is invoked repeatedly with [duration] intervals until
    * canceled. A negative duration is treated similar to a duration of 0.
    */
   external factory Timer.periodic(Duration duration,
                                   void callback(Timer timer));
 
   /**
    * Runs the given [callback] asynchronously as soon as possible.
    */
   static void run(void callback()) {
-    schedule() {
+    // Optimizing a group of Timer.run callbacks to be executed in the
+    // same Timer callback.
+    _runCallbacks.add(callback);
+    if (_runCallbacks.length == 1) {
       new Timer(const Duration(milliseconds: 0), () {
         List runCallbacks = _runCallbacks;
         // Create new list to make sure we don't call newly added callbacks in
         // this event.
         _runCallbacks = [];
         for (int i = 0; i < runCallbacks.length; i++) {
           Function callback = runCallbacks[i];
           try {
             callback();
           } catch (e) {
             List newCallbacks = _runCallbacks;
             _runCallbacks = [];
             i++;  // Skip the current;
             _runCallbacks.addAll(
                 runCallbacks.sublist(i));
             _runCallbacks.addAll(newCallbacks);
-            if (!_runCallbacks.isEmpty) schedule();
             throw;
           }
         }
       });
     }
-
-    // Optimizing a group of Timer.run callbacks to be executed in the
-    // same Timer callback.
-    _runCallbacks.add(callback);
-    if (_runCallbacks.length == 1) schedule();
   }
 
   /**
    * Cancels the timer.
    */
   void cancel();
 }