Index: sdk/lib/async/stream_impl.dart |
diff --git a/sdk/lib/async/stream_impl.dart b/sdk/lib/async/stream_impl.dart |
index 375844cdcdf535ce2d3a502714e3fc4363e56a59..e46ba50aedd64a76028251fa5b492692d9ce7c0b 100644 |
--- a/sdk/lib/async/stream_impl.dart |
+++ b/sdk/lib/async/stream_impl.dart |
@@ -694,9 +694,9 @@ class _StreamImplEvents extends _PendingEvents { |
} |
} |
-class _MultiplexerLinkedList { |
- _MultiplexerLinkedList _next; |
- _MultiplexerLinkedList _previous; |
+class _BroadcastLinkedList { |
+ _BroadcastLinkedList _next; |
+ _BroadcastLinkedList _previous; |
void _unlink() { |
_previous._next = _next; |
@@ -704,8 +704,8 @@ class _MultiplexerLinkedList { |
_next = _previous = this; |
} |
- void _insertBefore(_MultiplexerLinkedList newNext) { |
- _MultiplexerLinkedList newPrevious = newNext._previous; |
+ void _insertBefore(_BroadcastLinkedList newNext) { |
+ _BroadcastLinkedList newPrevious = newNext._previous; |
newPrevious._next = this; |
newNext._previous = _previous; |
_previous._next = newNext; |
@@ -715,11 +715,11 @@ class _MultiplexerLinkedList { |
class _AsBroadcastStream<T> extends Stream<T> { |
final Stream<T> _source; |
- _BufferingMultiplexStreamController<T> _controller; |
+ _AsBroadcastStreamController<T> _controller; |
StreamSubscription<T> _subscription; |
_AsBroadcastStream(this._source) { |
- _controller = new _BufferingMultiplexStreamController<T>(null, _onCancel); |
+ _controller = new _AsBroadcastStreamController<T>(null, _onCancel); |
} |
bool get isBroadcast => true; |