No longer work around issue 7761.

pkg/http/lib/src/utils.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.
 
 library utils;
 
 import 'dart:async';
 import 'dart:crypto';
 import 'dart:io';
 import 'dart:scalarlist';
@@ skipping 154 matching lines @@
 // TODO(nweiz): remove this once issue 7785 is fixed.
 /// Wraps [stream] in a [StreamConsumer] so that [Stream]s can by piped into it
 /// using [Stream.pipe].
 StreamConsumer<List<int>, dynamic> wrapOutputStream(OutputStream stream) =>
   new _OutputStreamConsumer(stream);
 
 /// A [StreamConsumer] that pipes data into an [OutputStream].
 class _OutputStreamConsumer implements StreamConsumer<List<int>, dynamic> {
   final OutputStream _outputStream;
 
-  _OutputStreamConsumer(this._outputStream)
-    : super();
+  _OutputStreamConsumer(this._outputStream);
 
   Future consume(Stream<List<int>> stream) {
     // TODO(nweiz): we have to manually keep track of whether or not the
     // completer has completed since the output stream could signal an error
     // after close() has been called but before it has shut down internally. See
     // the following TODO.
     var completed = false;
     var completer = new Completer();
-    stream.listen((data) => _outputStream.write(data), onDone: () {
-      _outputStream.close();
-      // TODO(nweiz): wait until _outputStream.onClosed is called once issue
-      // 7761 is fixed.
-      if (!completed) completer.complete();
-      completed = true;
-    });
+    stream.listen((data) {
+      // Writing empty data to a closed stream can cause errors.
+      if (data.isEmpty) return;
+
+      // TODO(nweiz): remove this try/catch when issue 7836 is fixed.
+      try {
+        _outputStream.write(data);
+      } catch (e, stack) {
+        if (!completed) completer.completeError(e, stack);
+        completed = true;
+      }
+    }, onDone: () => _outputStream.close());
 
     _outputStream.onError = (e) {
       if (!completed) completer.completeError(e);
       completed = true;
     };
 
+    _outputStream.onClosed = () {
+      if (!completed) completer.complete();
+      completed = true;
+    };
+
     return completer.future;
   }
 }
 
 // TODO(nweiz): remove this when issue 7786 is fixed.
 /// Pipes all data and errors from [stream] into [sink]. When [stream] is done,
 /// [sink] is closed and the returned [Future] is completed.
 Future store(Stream stream, StreamSink sink) {
   var completer = new Completer();
   stream.listen(sink.add,
@@ skipping 85 matching lines @@
 /// The return values of all [Future]s are discarded. Any errors will cause the
 /// iteration to stop and will be piped through the return value.
 Future forEachFuture(Iterable input, Future fn(element)) {
   var iterator = input.iterator;
   Future nextElement(_) {
     if (!iterator.moveNext()) return new Future.immediate(null);
     return fn(iterator.current).then(nextElement);
   }
   return nextElement(null);
 }