| OLD | NEW | 
|---|
| 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  Loading... | 
| 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  Loading... | 
| 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 } | 
| OLD | NEW | 
|---|