Add Stream.drain() method.

sdk/lib/async/stream.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.async;
 
 // -------------------------------------------------------------------
 // Core Stream types
 // -------------------------------------------------------------------
 
@@ skipping 481 matching lines @@
       },
       onError: future._setError,
       onDone: () {
         future._setValue(result);
       },
       cancelOnError: true);
     return future;
   }
 
   /**
+   * Discard all data on the stream, but signal when it's done or an error
+   * occoured.

[floitsch, 2013/05/24 11:50:42]

Discards ... signals ... occured

Add optional argument that will be the result of the future. (similar to
asFuture).

[Anders Johnsen, 2013/05/24 12:45:03]

Done.

+   */
+  Future drain() => listen(null).asFuture();

[floitsch, 2013/05/24 11:50:42]

list(null, cancelOnError: true), documenting that you take this approach.

[Anders Johnsen, 2013/05/24 12:45:03]

Done.

[Søren Gjesse, 2013/05/24 14:02:04]

Should it maybe have a named optional argument "ignoreError"?

[floitsch, 2013/05/24 16:21:33]

I think that this should be kept as simple as possible.
If you want more fancy behavior just write the 15 characters.

+
+  /**
    * Provides at most the first [n] values of this stream.
    *
    * Forwards the first [n] data events of this stream, and all error
    * events, to the returned stream, and ends with a done event.
    *
    * If this stream produces fewer than [count] values before it's done,
    * so will the returned stream.
    */
   Stream<T> take(int count) {
     return new _TakeStream(this, count);
@@ skipping 700 matching lines @@
 }
 
 class _EventOutputSinkWrapper<T> extends EventSink<T> {
   _EventOutputSink _sink;
   _EventOutputSinkWrapper(this._sink);
 
   void add(T data) { _sink._sendData(data); }
   void addError(error) { _sink._sendError(error); }
   void close() { _sink._sendDone(); }
 }