| 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 patch class RawServerSocket { | 5 patch class RawServerSocket { |
| 6 /* patch */ static Future<RawServerSocket> bind(address, | 6 /* patch */ static Future<RawServerSocket> bind(address, |
| 7 int port, | 7 int port, |
| 8 {int backlog: 0, | 8 {int backlog: 0, |
| 9 bool v6Only: false}) { | 9 bool v6Only: false}) { |
| 10 return _RawServerSocket.bind(address, port, backlog, v6Only); | 10 return _RawServerSocket.bind(address, port, backlog, v6Only); |
| (...skipping 757 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 768 return new _RawSocket(native); | 768 return new _RawSocket(native); |
| 769 } | 769 } |
| 770 | 770 |
| 771 factory _RawSocket._readPipe(int fd) { | 771 factory _RawSocket._readPipe(int fd) { |
| 772 var native = new _NativeSocket.pipe(); | 772 var native = new _NativeSocket.pipe(); |
| 773 native.isClosedWrite = true; | 773 native.isClosedWrite = true; |
| 774 if (fd != null) _getStdioHandle(native, fd); | 774 if (fd != null) _getStdioHandle(native, fd); |
| 775 var result = new _RawSocket(native); | 775 var result = new _RawSocket(native); |
| 776 result._isMacOSTerminalInput = | 776 result._isMacOSTerminalInput = |
| 777 Platform.isMacOS && | 777 Platform.isMacOS && |
| 778 _StdIOUtils._socketType(result) == _STDIO_HANDLE_TYPE_TERMINAL; | 778 _StdIOUtils._socketType(result._socket) == _STDIO_HANDLE_TYPE_TERMINAL; |
| 779 return result; | 779 return result; |
| 780 } | 780 } |
| 781 | 781 |
| 782 StreamSubscription<RawSocketEvent> listen(void onData(RawSocketEvent event), | 782 StreamSubscription<RawSocketEvent> listen(void onData(RawSocketEvent event), |
| 783 {void onError(Object error), | 783 {void onError(Object error), |
| 784 void onDone(), | 784 void onDone(), |
| 785 bool cancelOnError}) { | 785 bool cancelOnError}) { |
| 786 return _controller.stream.listen( | 786 return _controller.stream.listen( |
| 787 onData, | 787 onData, |
| 788 onError: onError, | 788 onError: onError, |
| (...skipping 403 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1192 if (_detachReady != null) { | 1192 if (_detachReady != null) { |
| 1193 _detachReady.complete(null); | 1193 _detachReady.complete(null); |
| 1194 } else { | 1194 } else { |
| 1195 if (_raw != null) { | 1195 if (_raw != null) { |
| 1196 _raw.shutdown(SocketDirection.SEND); | 1196 _raw.shutdown(SocketDirection.SEND); |
| 1197 _disableWriteEvent(); | 1197 _disableWriteEvent(); |
| 1198 } | 1198 } |
| 1199 } | 1199 } |
| 1200 } | 1200 } |
| 1201 } | 1201 } |
| OLD | NEW |