Fix pub to close connection to dartlang.org when it's done downloading

utils/pub/io.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.
 
 /**
  * Helper functionality to make working with IO easier.
  */
 #library('io');
 
 #import('dart:io');
@@ skipping 273 matching lines @@
  */
 // TODO(rnystrom): Should this be async?
 String getFullPath(entry) => new File(_getPath(entry)).fullPathSync();
 
 /**
  * Opens an input stream for a HTTP GET request to [uri], which may be a
  * [String] or [Uri].
  */
 InputStream httpGet(uri) {
   var resultStream = new ListInputStream();
-  var connection = new HttpClient().getUrl(_getUri(uri));
+  var client = new HttpClient();
+  var connection = client.getUrl(_getUri(uri));
 
   // TODO(nweiz): propagate this error to the return value. See issue 3657.
   connection.onError = (e) { throw e; };
   connection.onResponse = (response) {
     if (response.statusCode >= 400) {
       // TODO(nweiz): propagate this error to the return value. See issue 3657.
       throw new Exception(
           "HTTP request for $uri failed with status ${response.statusCode}");
     }
 
-    pipeInputToInput(response.inputStream, resultStream);
+    pipeInputToInput(response.inputStream, resultStream, client.shutdown);
   };
 
   return resultStream;
 }
 
 /**
  * Takes all input from [source] and writes it to [sink].
  *
  * [onClosed] is called when [source] is closed.
  */
@@ skipping 168 matching lines @@
   return new Directory(entry);
 }
 
 /**
  * Gets a [Uri] for [uri], which can either already be one, or be a [String].
  */
 Uri _getUri(uri) {
   if (uri is Uri) return uri;
   return new Uri.fromString(uri);
 }