Remove explicit delayed futures in dart:io.

sdk/lib/io/io_sink.dart

 // Copyright (c) 2013, 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;
 
 /**
  * Helper class to wrap a [StreamConsumer<List<int>>] and provide
  * utility functions for writing to the StreamConsumer directly. The
  * [IOSink] buffers the input given by all [StringSink] methods and will delay
@@ skipping 98 matching lines @@
   void _closeTarget() {
     _target.close()
         .then((value) => _completeDone(value: value),
               onError: (error) => _completeDone(error: error));
   }
 
   Future get done => _doneFuture;
 
   void _completeDone({value, error}) {
     if (_doneCompleter == null) return;
-    var tmp = _doneCompleter;
+    if (error == null) {
+      _doneCompleter.complete(value);
+    } else {
+      _doneCompleter.completeError(error);
+    }
     _doneCompleter = null;
-    if (error == null) {
-      tmp.complete(value);
-    } else {
-      tmp.completeError(error);
-    }
   }
 
   StreamController<T> get _controller {
     if (_isBound) {
       throw new StateError("StreamSink is bound to a stream");
     }
     if (_isClosed) {
       throw new StateError("StreamSink is closed");
     }
     if (_controllerInstance == null) {
       _controllerInstance = new StreamController<T>();
       _controllerCompleter = new Completer();
       _target.addStream(_controller.stream)
           .then(
               (_) {
                 if (_isBound) {
                   // A new stream takes over - forward values to that stream.
-                  var completer = _controllerCompleter;
+                  _controllerCompleter.complete();
                   _controllerCompleter = null;
                   _controllerInstance = null;
-                  completer.complete();
                 } else {
                   // No new stream, .close was called. Close _target.
                   _closeTarget();
                 }
               },
               onError: (error) {
                 if (_isBound) {
                   // A new stream takes over - forward errors to that stream.
-                  var completer = _controllerCompleter;
+                  _controllerCompleter.completeError(error);
                   _controllerCompleter = null;
                   _controllerInstance = null;
-                  completer.completeError(error);
                 } else {
                   // No new stream. No need to close target, as it have already
                   // failed.
                   _completeDone(error: error);
                 }
               });
     }
     return _controllerInstance;
   }
 }
@@ skipping 50 matching lines @@
 
   void writeln([Object obj = ""]) {
     write(obj);
     write("\n");
   }
 
   void writeCharCode(int charCode) {
     write(new String.fromCharCode(charCode));
   }
 }