Stream isolates.

sdk/lib/async/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.
 
 // -------------------------------------------------------------------
 // Default implementation of a stream with a controller for adding
 // events to the stream.
 // -------------------------------------------------------------------
 
 /**
@@ skipping 392 matching lines @@
     if (handleDone == null) handleDone = StreamController._nullDoneHandler;
     _onDone = handleDone;
   }
 
   void unsubscribe() { _controller._removeSubscription(this); }
 
   void pause(Signal resume) { _controller._pause(this, resume); }
 }
 
 /** Helper class for [ControllerSubcription] to store pending subscriptions. */
-class _PendingSubscriptionChanges implements _InternalLinkList {
+class _PendingSubscriptionChanges extends _InternalLinkList {
   List<_ControllerSubscription> pendingRemoves;
 
   /** Add a pending subscription. */
   void addSubscription(_ControllerSubscription subscription) {
     assert(_InternalLink.isUnlinked(subscription));
     _InternalLinkList.add(this, subscription);
   }
 
   /** Add a pending unsubscription. */
   void removeSubscription(_ControllerSubscription subscription) {
@@ skipping 107 matching lines @@
  * An element is considered part of a list if it is in the list's cycle.
  * There should never be more than one "list" object in a cycle.
  */
 abstract class _InternalLinkList extends _InternalLink {
     /**
    * Adds an element to a list, just before the header link.
    *
    * This effectively adds it at the end of the list.
    */
   static void add(_InternalLinkList list, _InternalLink element) {
-    if (!_InternalLink.isUnlinked(element)) _InternalLink._unlink(element);
+    if (!_InternalLink.isUnlinked(element)) _InternalLink.unlink(element);
     _InternalLink listEnd = list._previousLink;
     listEnd._nextLink = element;
     list._previousLink = element;
     element._previousLink = listEnd;
     element._nextLink = list;
   }
 
   /** Removes an element from its list. */
   static void remove(_InternalLink element) {
     _InternalLink.unlink(element);
   }
 
   /** Check whether a list contains no elements, only the header link. */
   static bool isEmpty(_InternalLinkList list) => _InternalLink.isUnlinked(list);
 
   /** Moves all elements from the list [other] to [list]. */
-  static void addAll(InternalLinkList list, InternalLinkList other) {
+  static void addAll(_InternalLinkList list, _InternalLinkList other) {
     if (isEmpty(other)) return;
     if (isEmpty(list)) {
       list._nextLink = other._nextLink;
       list._previousLink = other._previousLink;
+      list._nextLink._previousLink = list;
+      list._previousLink._nextLink = list;
     } else {
       _InternalLink listLast = list._previousLink;
       _InternalLink otherNext = other._nextLink;
       listLast._nextLink = otherNext;
       otherNext._previousLink = listLast;
       _InternalLink otherLast = other._previousLink;
       list._previousLink = otherLast;
       otherLast._nextLink = list;
     }
     other._nextLink = other._previousLink = other;
   }
 }