OLD | NEW |
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 class _BaseDataInputStream { | 5 class _BaseDataInputStream { |
6 abstract int available(); | 6 abstract int available(); |
7 | 7 |
8 List<int> read([int len]) { | 8 List<int> read([int len]) { |
9 if (_closeCallbackCalled || _scheduledCloseCallback != null) return null; | 9 if (_closeCallbackCalled || _scheduledCloseCallback != null) return null; |
10 int bytesToRead = available(); | 10 int bytesToRead = available(); |
11 if (bytesToRead == 0) { | 11 if (bytesToRead == 0) { |
12 _checkScheduleCallbacks(); | 12 _checkScheduleCallbacks(); |
13 return null; | 13 return null; |
14 } | 14 } |
15 if (len !== null) { | 15 if (len !== null) { |
16 if (len <= 0) { | 16 if (len <= 0) { |
17 throw new StreamException("Illegal length $len"); | 17 throw new StreamException("Illegal length $len"); |
18 } else if (bytesToRead > len) { | 18 } else if (bytesToRead > len) { |
19 bytesToRead = len; | 19 bytesToRead = len; |
20 } | 20 } |
21 } | 21 } |
22 return _read(bytesToRead); | 22 return _read(bytesToRead); |
23 } | 23 } |
24 | 24 |
25 int readInto(List<int> buffer, [int offset = 0, int len]) { | 25 int readInto(List<int> buffer, [int offset = 0, int len]) { |
26 if (_closeCallbackCalled || _scheduledCloseCallback != null) return 0; | 26 if (_closeCallbackCalled || _scheduledCloseCallback != null) return 0; |
27 if (len === null) len = buffer.length; | 27 if (len === null) len = buffer.length; |
28 if (offset < 0) throw new StreamException("Illegal offset $offset"); | 28 if (offset < 0) throw new StreamException("Illegal offset $offset"); |
29 if (len < 0) throw new StreamException("Illegal length $len"); | 29 if (len < 0) throw new StreamException("Illegal length $len"); |
30 int bytesToRead = Math.min(len, available()); | 30 int bytesToRead = min(len, available()); |
31 return _readInto(buffer, offset, bytesToRead); | 31 return _readInto(buffer, offset, bytesToRead); |
32 } | 32 } |
33 | 33 |
34 void pipe(OutputStream output, [bool close = true]) { | 34 void pipe(OutputStream output, [bool close = true]) { |
35 _pipe(this, output, close: close); | 35 _pipe(this, output, close: close); |
36 } | 36 } |
37 | 37 |
38 void close() { | 38 void close() { |
39 _cancelScheduledDataCallback(); | 39 _cancelScheduledDataCallback(); |
40 _close(); | 40 _close(); |
(...skipping 161 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
202 void _reportError(e) { | 202 void _reportError(e) { |
203 if (_onError != null) { | 203 if (_onError != null) { |
204 _onError(e); | 204 _onError(e); |
205 } else { | 205 } else { |
206 throw e; | 206 throw e; |
207 } | 207 } |
208 } | 208 } |
209 | 209 |
210 Function _onError; | 210 Function _onError; |
211 } | 211 } |
OLD | NEW |