| Index: sdk/lib/io/http_parser.dart
|
| diff --git a/sdk/lib/io/http_parser.dart b/sdk/lib/io/http_parser.dart
|
| index 9a2f6b9bfdc0ed40b0ef93a7e71c6d95cd7b61bd..a6662cf87a577b3c256da7eb246dc7300e79c5a0 100644
|
| --- a/sdk/lib/io/http_parser.dart
|
| +++ b/sdk/lib/io/http_parser.dart
|
| @@ -125,12 +125,12 @@ class _HttpDetachedIncoming extends Stream<List<int>> {
|
| StreamSubscription<List<int>> listen(void onData(List<int> event),
|
| {void onError(AsyncError error),
|
| void onDone(),
|
| - bool unsubscribeOnError}) {
|
| + bool cancelOnError}) {
|
| return controller.stream.listen(
|
| onData,
|
| onError: onError,
|
| onDone: onDone,
|
| - unsubscribeOnError: unsubscribeOnError);
|
| + cancelOnError: cancelOnError);
|
| }
|
|
|
| void resume() {
|
| @@ -218,11 +218,11 @@ class _HttpParser
|
| StreamSubscription<_HttpIncoming> listen(void onData(_HttpIncoming event),
|
| {void onError(AsyncError error),
|
| void onDone(),
|
| - bool unsubscribeOnError}) {
|
| + bool cancelOnError}) {
|
| return _controller.stream.listen(onData,
|
| onError: onError,
|
| onDone: onDone,
|
| - unsubscribeOnError: unsubscribeOnError);
|
| + cancelOnError: cancelOnError);
|
| }
|
|
|
| Future<_HttpParser> addStream(Stream<List<int>> stream) {
|
|
|