Fix bad handling of done events in _ForwardingStream.

tests/lib/async/stream_transform_test.dart

Index: tests/lib/async/stream_transform_test.dart
diff --git a/tests/lib/async/stream_transform_test.dart b/tests/lib/async/stream_transform_test.dart
new file mode 100644
index 0000000000000000000000000000000000000000..acbe03488bc49e0eadabca3c1218fb77dbb9a61e
--- /dev/null
+++ b/tests/lib/async/stream_transform_test.dart
@@ -0,0 +1,48 @@
+// Copyright (c) 2011, 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 stream_transform_test;
+
+import 'dart:async';
+import '../../../pkg/unittest/lib/unittest.dart';
+import 'event_helper.dart';
+
+
+main() {
+  // Regression tests for http://dartbug.com/8311
+
+  test("simpleDone", () {
+    StreamController c = new StreamController();
+    Stream out = c.stream.catchError((x){}).catchError((x){});
+    out.listen((v){}, onDone: expectAsync0(() {}));
+    // Should not throw.
+    c.close();
+  });
+
+  test("with events", () {
+    StreamController c = new StreamController();
+    Events expected = new Events.fromIterable([6, 8, 10]);
+    Events input = new Events.fromIterable([1, 2, 3, 4, 5]);
+    Events actual = new Events.capture(
+        c.stream.map((x) => x * 2).where((x) => x > 5));
+    actual.onDone(() {

[floitsch, 2013/02/05 15:09:51]

expectAsync0

[Lasse Reichstein Nielsen, 2013/02/07 10:16:58]

Done.

+      Expect.listEquals(expected.events, actual.events);
+    });
+    input.replay(c);
+  });
+
+  test("paused events", () {
+    StreamController c = new StreamController();
+    Events expected = new Events.fromIterable([6, 8, 10]);
+    Events input = new Events.fromIterable([1, 2, 3, 4, 5]);
+    Events actual = new Events.capture(
+        c.stream.map((x) => x * 2).where((x) => x > 5));
+    actual.onDone(expectAsync0(() {
+      Expect.listEquals(expected.events, actual.events);
+    }));
+    actual.pause();
+    input.replay(c);
+    actual.resume();
+  });
+}

[floitsch, 2013/02/05 15:09:51]

more tests! :)
some other transformations would be nice.
map.map
...
simple stuff, but just to get a little bit more coverage.

[Lasse Reichstein Nielsen, 2013/02/07 10:16:58]

That won't give any more coverage for this bug. It's in their common superclass,
so it makes no difference which two you use.
I've added a few more to the existing case, to cover chains longer than two.