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

Side by Side Diff: sdk/lib/async/stream_impl.dart

Issue 2973823002: Revert "Remaining private libs" (Closed)
Patch Set: Created 3 years, 5 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 unified diff | Download patch
« no previous file with comments | « sdk/lib/async/stream_controller.dart ('k') | sdk/lib/async/stream_pipe.dart » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file 1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file
2 // for details. All rights reserved. Use of this source code is governed by a 2 // for details. All rights reserved. Use of this source code is governed by a
3 // BSD-style license that can be found in the LICENSE file. 3 // BSD-style license that can be found in the LICENSE file.
4 4
5 part of "dart:async"; 5 part of "async.dart";
6 6
7 /** Abstract and private interface for a place to put events. */ 7 /** Abstract and private interface for a place to put events. */
8 abstract class _EventSink<T> { 8 abstract class _EventSink<T> {
9 void _add(T data); 9 void _add(T data);
10 void _addError(Object error, StackTrace stackTrace); 10 void _addError(Object error, StackTrace stackTrace);
11 void _close(); 11 void _close();
12 } 12 }
13 13
14 /** 14 /**
15 * Abstract and private interface for a place to send events. 15 * Abstract and private interface for a place to send events.
(...skipping 1026 matching lines...) Expand 10 before | Expand all | Expand 10 after
1042 1042
1043 /** An empty broadcast stream, sending a done event as soon as possible. */ 1043 /** An empty broadcast stream, sending a done event as soon as possible. */
1044 class _EmptyStream<T> extends Stream<T> { 1044 class _EmptyStream<T> extends Stream<T> {
1045 const _EmptyStream() : super._internal(); 1045 const _EmptyStream() : super._internal();
1046 bool get isBroadcast => true; 1046 bool get isBroadcast => true;
1047 StreamSubscription<T> listen(void onData(T data), 1047 StreamSubscription<T> listen(void onData(T data),
1048 {Function onError, void onDone(), bool cancelOnError}) { 1048 {Function onError, void onDone(), bool cancelOnError}) {
1049 return new _DoneStreamSubscription<T>(onDone); 1049 return new _DoneStreamSubscription<T>(onDone);
1050 } 1050 }
1051 } 1051 }
OLDNEW
« no previous file with comments | « sdk/lib/async/stream_controller.dart ('k') | sdk/lib/async/stream_pipe.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698