Expose the cancelOnError in the StreamController.addStream.

tests/lib/async/stream_controller_async_test.dart

 // 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.
 
 // Test the basic StreamController and StreamController.singleSubscription.
 library stream_controller_async_test;
 
 import 'dart:async';
 import 'dart:isolate';
 import "package:expect/expect.dart";
@@ skipping 661 matching lines @@
           } else {
             Expect.listEquals(expected.events, actual.events);
             done();
           }
         });
   });
 
   test("$type-controller-addstream-error-stop", () {
     // Check that addStream defaults to ending after the first error.
     var done = expectAsync0((){});
-    var c = broadcast ? new StreamController.broadcast(sync: sync)
-                      : new StreamController(sync: sync);
-    var stream = asBroadcast ? c.stream.asBroadcastStream() : c.stream;
+    StreamController c = broadcast
+        ? new StreamController.broadcast(sync: sync)
+        : new StreamController(sync: sync);
+    Stream stream = asBroadcast ? c.stream.asBroadcastStream() : c.stream;
     var actual = new Events.capture(stream);
 
     var source = new Events();
     source..add(1)..add(2)..error("BAD")..add(3)..error("FAIL")..close();
 
     var expected = new Events()..add(1)..add(2)..error("BAD")..close();
     StreamController sourceController = new StreamController();
     c.addStream(sourceController.stream).then((_) {
       c.close().then((_) {
         Expect.listEquals(expected.events, actual.events);
         done();
       });
     });
 
     source.replay(sourceController);
   });
 
   test("$type-controller-addstream-error-forward", () {
     // Check that addStream with cancelOnError:false passes all data and errors
     // to the controller.
     var done = expectAsync0((){});
-    var c = broadcast ? new StreamController.broadcast(sync: sync)
-                      : new StreamController(sync: sync);
-    var stream = asBroadcast ? c.stream.asBroadcastStream() : c.stream;
+    StreamController c = broadcast
+        ? new StreamController.broadcast(sync: sync)
+        : new StreamController(sync: sync);
+    Stream stream = asBroadcast ? c.stream.asBroadcastStream() : c.stream;
     var actual = new Events.capture(stream);
 
     var source = new Events();
     source..add(1)..add(2)..addError("BAD")..add(3)..addError("FAIL")..close();
 
     StreamController sourceController = new StreamController();
     c.addStream(sourceController.stream, cancelOnError: false).then((_) {
       c.close().then((_) {
         Expect.listEquals(source.events, actual.events);
         done();
       });
     });
 
     source.replay(sourceController);
   });
 
   test("$type-controller-addstream-twice", () {
     // Using addStream twice on the same stream
     var done = expectAsync0((){});
-    var c = broadcast ? new StreamController.broadcast(sync: sync)
-                      : new StreamController(sync: sync);
-    var stream = asBroadcast ? c.stream.asBroadcastStream() : c.stream;
+    StreamController c = broadcast
+        ? new StreamController.broadcast(sync: sync)
+        : new StreamController(sync: sync);
+    Stream stream = asBroadcast ? c.stream.asBroadcastStream() : c.stream;
     var actual = new Events.capture(stream);
 
     // Streams of five events, throws on 3.
     Stream s1 = new Stream.fromIterable([1,2,3,4,5])
                     .map((x) => (x == 3 ? throw x : x));
     Stream s2 = new Stream.fromIterable([1,2,3,4,5])
                     .map((x) => (x == 3 ? throw x : x));
 
     Events expected = new Events();
     expected..add(1)..add(2)..error(3);
@@ skipping 19 matching lines @@
   testRethrow();
   testBroadcastController();
   testAsBroadcast();
   testSink(sync: true, broadcast: false, asBroadcast: false);
   testSink(sync: true, broadcast: false, asBroadcast: true);
   testSink(sync: true, broadcast: true, asBroadcast: false);
   testSink(sync: false, broadcast: false, asBroadcast: false);
   testSink(sync: false, broadcast: false, asBroadcast: true);
   testSink(sync: false, broadcast: true, asBroadcast: false);
 }