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

Side by Side Diff: sdk/lib/io/file_impl.dart

Issue 14103010: Change hasSubscribers to hasListener. (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) 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 part of dart.io; 5 part of dart.io;
6 6
7 // Read the file in blocks of size 64k. 7 // Read the file in blocks of size 64k.
8 const int _BLOCK_SIZE = 64 * 1024; 8 const int _BLOCK_SIZE = 64 * 1024;
9 9
10 10
(...skipping 112 matching lines...) Expand 10 before | Expand all | Expand 10 after
123 _paused = false; 123 _paused = false;
124 if (_currentBlock != null) { 124 if (_currentBlock != null) {
125 _controller.add(_currentBlock); 125 _controller.add(_currentBlock);
126 _currentBlock = null; 126 _currentBlock = null;
127 } 127 }
128 // Resume reading unless we are already done. 128 // Resume reading unless we are already done.
129 if (_openedFile != null) _readBlock(); 129 if (_openedFile != null) _readBlock();
130 } 130 }
131 131
132 void _onSubscriptionStateChange() { 132 void _onSubscriptionStateChange() {
133 if (_controller.hasSubscribers) { 133 if (_controller.hasListener) {
134 _start(); 134 _start();
135 } else { 135 } else {
136 _unsubscribed = true; 136 _unsubscribed = true;
137 _closeFile(); 137 _closeFile();
138 } 138 }
139 } 139 }
140 140
141 void _onPauseStateChange() { 141 void _onPauseStateChange() {
142 if (_controller.isPaused) { 142 if (_controller.isPaused) {
143 _paused = true; 143 _paused = true;
(...skipping 910 matching lines...) Expand 10 before | Expand all | Expand 10 after
1054 new FileIOException("File closed '$_path'")); 1054 new FileIOException("File closed '$_path'"));
1055 }); 1055 });
1056 return completer.future; 1056 return completer.future;
1057 } 1057 }
1058 1058
1059 final String _path; 1059 final String _path;
1060 int _id; 1060 int _id;
1061 1061
1062 SendPort _fileService; 1062 SendPort _fileService;
1063 } 1063 }
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698