| 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 // Global constants. | 7 // Global constants. |
| 8 class _Const { | 8 class _Const { |
| 9 // Bytes for "HTTP". | 9 // Bytes for "HTTP". |
| 10 static const HTTP = const [72, 84, 84, 80]; | 10 static const HTTP = const [72, 84, 84, 80]; |
| (...skipping 102 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 113 int _pauseCount = 1; | 113 int _pauseCount = 1; |
| 114 Function _userOnData; | 114 Function _userOnData; |
| 115 bool _scheduled = false; | 115 bool _scheduled = false; |
| 116 | 116 |
| 117 _HttpDetachedStreamSubscription(this._subscription, | 117 _HttpDetachedStreamSubscription(this._subscription, |
| 118 this._injectData, | 118 this._injectData, |
| 119 this._userOnData); | 119 this._userOnData); |
| 120 | 120 |
| 121 bool get isPaused => _subscription.isPaused; | 121 bool get isPaused => _subscription.isPaused; |
| 122 | 122 |
| 123 Future/*<T>*/ asFuture/*<T>*/([/*=T*/ futureValue]) => | 123 Future<T> asFuture<T>([T futureValue]) => |
| 124 _subscription.asFuture/*<T>*/(futureValue); | 124 _subscription.asFuture<T>(futureValue); |
| 125 | 125 |
| 126 Future cancel() { | 126 Future cancel() { |
| 127 _isCanceled = true; | 127 _isCanceled = true; |
| 128 _injectData = null; | 128 _injectData = null; |
| 129 return _subscription.cancel(); | 129 return _subscription.cancel(); |
| 130 } | 130 } |
| 131 | 131 |
| 132 void onData(void handleData(List<int> data)) { | 132 void onData(void handleData(List<int> data)) { |
| 133 _userOnData = handleData; | 133 _userOnData = handleData; |
| 134 _subscription.onData(handleData); | 134 _subscription.onData(handleData); |
| (...skipping 929 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1064 } | 1064 } |
| 1065 } | 1065 } |
| 1066 | 1066 |
| 1067 void _reportError(error, [stackTrace]) { | 1067 void _reportError(error, [stackTrace]) { |
| 1068 if (_socketSubscription != null) _socketSubscription.cancel(); | 1068 if (_socketSubscription != null) _socketSubscription.cancel(); |
| 1069 _state = _State.FAILURE; | 1069 _state = _State.FAILURE; |
| 1070 _controller.addError(error, stackTrace); | 1070 _controller.addError(error, stackTrace); |
| 1071 _controller.close(); | 1071 _controller.close(); |
| 1072 } | 1072 } |
| 1073 } | 1073 } |
| OLD | NEW |