Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1463)

Unified Diff: sdk/lib/async/stream_impl.dart

Issue 16125005: Make new StreamController be async by default. (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Address review comments Created 7 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « sdk/lib/async/stream_controller.dart ('k') | sdk/lib/html/dart2js/html_dart2js.dart » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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;
« no previous file with comments | « sdk/lib/async/stream_controller.dart ('k') | sdk/lib/html/dart2js/html_dart2js.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698