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

Side by Side Diff: lib/src/stream_pool.dart

Issue 1578413003: Get rid of all the library tags. (Closed) Base URL: git@github.com:dart-lang/glob@master
Patch Set: Created 4 years, 11 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 | « lib/src/parser.dart ('k') | lib/src/utils.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) 2013, the Dart project authors. Please see the AUTHORS file 1 // Copyright (c) 2013, 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 library glob.stream_pool;
6
7 import 'dart:async'; 5 import 'dart:async';
8 6
9 /// A pool of streams whose events are unified and emitted through a central 7 /// A pool of streams whose events are unified and emitted through a central
10 /// stream. 8 /// stream.
11 class StreamPool<T> { 9 class StreamPool<T> {
12 /// The stream through which all events from streams in the pool are emitted. 10 /// The stream through which all events from streams in the pool are emitted.
13 Stream<T> get stream => _controller.stream; 11 Stream<T> get stream => _controller.stream;
14 final StreamController<T> _controller; 12 final StreamController<T> _controller;
15 13
16 /// Subscriptions to the streams that make up the pool. 14 /// Subscriptions to the streams that make up the pool.
(...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after
67 _subscriptions.clear(); 65 _subscriptions.clear();
68 _controller.close(); 66 _controller.close();
69 } 67 }
70 68
71 /// The next time this pool becomes empty, close it. 69 /// The next time this pool becomes empty, close it.
72 void closeWhenEmpty() { 70 void closeWhenEmpty() {
73 if (_subscriptions.isEmpty) close(); 71 if (_subscriptions.isEmpty) close();
74 _closeWhenEmpty = true; 72 _closeWhenEmpty = true;
75 } 73 }
76 } 74 }
OLDNEW
« no previous file with comments | « lib/src/parser.dart ('k') | lib/src/utils.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698