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

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

Issue 14150002: Remove StreamSink(replaced by EventSink) and make IOSink extend EventSink. (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Created 7 years, 8 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 | Annotate | Revision Log
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 dart.async;
6 6
7 typedef void _CollectionSinkCallback<T>(Collection<T> collection); 7 typedef void _CollectionSinkCallback<T>(Collection<T> collection);
8 typedef void _CollectionSinkErrorCallback(AsyncError error); 8 typedef void _CollectionSinkErrorCallback(AsyncError error);
9 9
10 /** 10 /**
11 * EventSink that stores incoming data in a collection. 11 * EventSink that stores incoming data in a collection.
12 * 12 *
13 * *Deprecated*. 13 * *Deprecated*.
14 */ 14 */
15 class CollectionSink<T> extends StreamSink<T> { 15 class CollectionSink<T> extends EventSink<T> {
16 // TODO(8997): Implement EventSink instead. 16 // TODO(8997): Implement EventSink instead.
17 final Collection<T> collection; 17 final Collection<T> collection;
18 final _CollectionSinkCallback<T> _callback; 18 final _CollectionSinkCallback<T> _callback;
19 final _CollectionSinkErrorCallback _errorCallback; 19 final _CollectionSinkErrorCallback _errorCallback;
20 bool _isClosed = false; 20 bool _isClosed = false;
21 21
22 /** 22 /**
23 * Create a sink that stores incoming values in a collection. 23 * Create a sink that stores incoming values in a collection.
24 * 24 *
25 * The [collection] is the collection to add the values to. 25 * The [collection] is the collection to add the values to.
(...skipping 16 matching lines...) Expand all
42 if (_isClosed) throw new StateError("Adding error to closed sink"); 42 if (_isClosed) throw new StateError("Adding error to closed sink");
43 if (_errorCallback != null) _errorCallback(error); 43 if (_errorCallback != null) _errorCallback(error);
44 } 44 }
45 45
46 void close() { 46 void close() {
47 if (_isClosed) throw new StateError("Closing closed sink"); 47 if (_isClosed) throw new StateError("Closing closed sink");
48 _isClosed = true; 48 _isClosed = true;
49 if (_callback != null) _callback(collection); 49 if (_callback != null) _callback(collection);
50 } 50 }
51 } 51 }
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698