Fixed bug in _ControllerStream.operator==.

sdk/lib/async/broadcast_stream_controller.dart

 // Copyright (c) 2012, 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;
 
-class _BroadcastStream<T> extends _StreamImpl<T> {
-  _BroadcastStreamController _controller;
-
-  _BroadcastStream(this._controller);
+class _BroadcastStream<T> extends _ControllerStream<T> {
+  _BroadcastStream(_StreamControllerLifecycle controller) : super(controller);
 
   bool get isBroadcast => true;
-
-  StreamSubscription<T> _createSubscription(
-      void onData(T data),
-      void onError(Object error),
-      void onDone(),
-      bool cancelOnError) =>
-    _controller._subscribe(onData, onError, onDone, cancelOnError);
 }
 
 abstract class _BroadcastSubscriptionLink {
   _BroadcastSubscriptionLink _next;
   _BroadcastSubscriptionLink _previous;
 }
 
 class _BroadcastSubscription<T> extends _ControllerSubscription<T>
                                 implements _BroadcastSubscriptionLink {
   static const int _STATE_EVENT_ID = 1;
@@ skipping 454 matching lines @@
     _pauseCount++;
   }
   void resume() { _resume(null); }
   void _resume(_) {
     if (_pauseCount > 0) _pauseCount--;
   }
   void cancel() {}
   bool get isPaused => _pauseCount > 0;
   Future asFuture([Object value]) => new _FutureImpl();
 }