| Index: runtime/bin/socket_patch.dart
|
| diff --git a/runtime/bin/socket_patch.dart b/runtime/bin/socket_patch.dart
|
| index 0316652c4b3ccc2ae28ef7e13a582a0eae5fb8ac..0fc72569ce845c9c0eb707693a1fd7321981f7f0 100644
|
| --- a/runtime/bin/socket_patch.dart
|
| +++ b/runtime/bin/socket_patch.dart
|
| @@ -450,12 +450,12 @@ class _RawServerSocket extends Stream<RawSocket>
|
| StreamSubscription<RawSocket> listen(void onData(RawSocket event),
|
| {void onError(AsyncError error),
|
| void onDone(),
|
| - bool unsubscribeOnError}) {
|
| + bool cancelOnError}) {
|
| return _controller.stream.listen(
|
| onData,
|
| onError: onError,
|
| onDone: onDone,
|
| - unsubscribeOnError: unsubscribeOnError);
|
| + cancelOnError: cancelOnError);
|
| }
|
|
|
| int get port => _socket.port;
|
| @@ -537,12 +537,12 @@ class _RawSocket extends Stream<RawSocketEvent>
|
| StreamSubscription<RawSocketEvent> listen(void onData(RawSocketEvent event),
|
| {void onError(AsyncError error),
|
| void onDone(),
|
| - bool unsubscribeOnError}) {
|
| + bool cancelOnError}) {
|
| return _controller.stream.listen(
|
| onData,
|
| onError: onError,
|
| onDone: onDone,
|
| - unsubscribeOnError: unsubscribeOnError);
|
| + cancelOnError: cancelOnError);
|
| }
|
|
|
| int available() => _socket.available();
|
| @@ -631,12 +631,12 @@ class _ServerSocket extends Stream<Socket>
|
| StreamSubscription<Socket> listen(void onData(Socket event),
|
| {void onError(AsyncError error),
|
| void onDone(),
|
| - bool unsubscribeOnError}) {
|
| + bool cancelOnError}) {
|
| return _socket.map((rawSocket) => new _Socket(rawSocket)).listen(
|
| onData,
|
| onError: onError,
|
| onDone: onDone,
|
| - unsubscribeOnError: unsubscribeOnError);
|
| + cancelOnError: cancelOnError);
|
| }
|
|
|
| int get port => _socket.port;
|
| @@ -688,7 +688,7 @@ class _SocketStreamConsumer extends StreamConsumer<List<int>> {
|
| onDone: () {
|
| done();
|
| },
|
| - unsubscribeOnError: true);
|
| + cancelOnError: true);
|
| }
|
| return streamCompleter.future;
|
| }
|
| @@ -786,12 +786,12 @@ class _Socket extends Stream<List<int>> implements Socket {
|
| 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);
|
| }
|
|
|
| Encoding get encoding => _sink.encoding;
|
| @@ -844,7 +844,7 @@ class _Socket extends Stream<List<int>> implements Socket {
|
| _subscription = _raw.listen(_onData,
|
| onError: _onError,
|
| onDone: _onDone,
|
| - unsubscribeOnError: true);
|
| + cancelOnError: true);
|
| }
|
| }
|
|
|
|
|