From 92ffe3101d122ddbce21770ce49a6cbc8fe0b991 Mon Sep 17 00:00:00 2001 From: "nweiz@google.com" <nweiz@google.com> Date: Sat, 2 Feb 2013 00:11:56 +0000 Subject: [PATCH] Fix a few breakages with Pub's oauth2 test. Review URL: https://codereview.chromium.org//12150006 git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge@18017 260f80e4-7a28-3924-810f-c04153c831b5 --- lib/src/utils.dart | 6 +++--- test/test_pub.dart | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/lib/src/utils.dart b/lib/src/utils.dart index 4cad26f5..1b41a4e1 100644 --- a/lib/src/utils.dart +++ b/lib/src/utils.dart @@ -178,9 +178,9 @@ Future streamFirst(Stream stream) { /// Returns a wrapped version of [stream] along with a [StreamSubscription] that /// can be used to control the wrapped stream. Pair<Stream, StreamSubscription> streamWithSubscription(Stream stream) { - var controller = stream.isSingleSubscription ? - new StreamController() : - new StreamController.multiSubscription(); + var controller = stream.isBroadcast ? + new StreamController.broadcast() : + new StreamController(); var subscription = stream.listen(controller.add, onError: controller.signalError, onDone: controller.close); diff --git a/test/test_pub.dart b/test/test_pub.dart index e16be37f..e8c4e5cf 100644 --- a/test/test_pub.dart +++ b/test/test_pub.dart @@ -1234,7 +1234,7 @@ class ScheduledProcess { Future<PubProcess> _processFuture; /// The process that's scheduled to run. It may be null. - Process _process; + PubProcess _process; /// The exit code of the scheduled program. It may be null. int _exitCode; -- GitLab