Optimize internals of multiplex-streams.

pkg/scheduled_test/lib/src/mock_clock.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.
 
 /// A library that wraps [Timer] in a way that can be mocked out in test code.
 /// Application code only needs to use [newTimer] to get an instance of [Timer].
 /// Then test code can call [mock] to mock out all new [Timer] instances so that
 /// they're controllable by a returned [Clock] object.
 library mock_clock;
 
@@ skipping 28 matching lines @@
 /// A clock that controls when mocked [Timer]s move forward in time. It starts
 /// at time 0 and advances forward millisecond-by-millisecond, broadcasting each
 /// tick on the [onTick] stream.
 class Clock {
   /// The current time of the clock, in milliseconds. Starts at 0.
   int get time => _time;
   int _time = 0;
 
   /// Controller providing streams for listening.
   StreamController<int> _multiplexController =
-      new StreamController<int>.multiplex();
+      new StreamController<int>.broadcast();
 
   Clock._();
 
   /// The stream of millisecond ticks of the clock.
   Stream<int> get onTick => _multiplexController.stream;
 
   /// Advances the clock forward by [milliseconds]. This works like synchronous
   /// code that takes [milliseconds] to execute; any [Timer]s that are scheduled
   /// to fire during the interval will do so asynchronously once control returns
   /// to the event loop.
@@ skipping 35 matching lines @@
       : _time = _clock.time + duration.inMilliseconds {
     _subscription = _clock.onTick.listen((time) {
       if (time < _time) return;
       _subscription.cancel();
       _callback();
     });
   }
 
   void cancel() => _subscription.cancel();
 }