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 |