Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2012, 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 /** | 7 /** |
| 8 * The [SecureServerSocket] is a server socket, providing a stream of high-level | 8 * The [SecureServerSocket] is a server socket, providing a stream of high-level |
| 9 * [Socket]s. | 9 * [Socket]s. |
| 10 * | 10 * |
| (...skipping 103 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 114 final String certificateName; | 114 final String certificateName; |
| 115 final bool requestClientCertificate; | 115 final bool requestClientCertificate; |
| 116 final bool requireClientCertificate; | 116 final bool requireClientCertificate; |
| 117 bool _closed = false; | 117 bool _closed = false; |
| 118 | 118 |
| 119 RawSecureServerSocket._(RawServerSocket serverSocket, | 119 RawSecureServerSocket._(RawServerSocket serverSocket, |
| 120 String this.certificateName, | 120 String this.certificateName, |
| 121 bool this.requestClientCertificate, | 121 bool this.requestClientCertificate, |
| 122 bool this.requireClientCertificate) { | 122 bool this.requireClientCertificate) { |
| 123 _socket = serverSocket; | 123 _socket = serverSocket; |
| 124 _controller = new StreamController<RawSecureSocket>( | 124 _controller = new StreamController<RawSecureSocket>(sync: true, |
|
floitsch
2013/05/30 12:13:48
next line.
Lasse Reichstein Nielsen
2013/05/31 05:51:59
Done.
| |
| 125 onListen: _onSubscriptionStateChange, | 125 onListen: _onSubscriptionStateChange, |
| 126 onPause: _onPauseStateChange, | 126 onPause: _onPauseStateChange, |
| 127 onResume: _onPauseStateChange, | 127 onResume: _onPauseStateChange, |
| 128 onCancel: _onSubscriptionStateChange); | 128 onCancel: _onSubscriptionStateChange); |
| 129 } | 129 } |
| 130 | 130 |
| 131 /** | 131 /** |
| 132 * Returns a future for a [RawSecureServerSocket]. When the future | 132 * Returns a future for a [RawSecureServerSocket]. When the future |
| 133 * completes the server socket is bound to the given [address] and | 133 * completes the server socket is bound to the given [address] and |
| 134 * [port] and has started listening on it. | 134 * [port] and has started listening on it. |
| (...skipping 122 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 257 _subscription = _socket.listen(_onData, | 257 _subscription = _socket.listen(_onData, |
| 258 onDone: _onDone, | 258 onDone: _onDone, |
| 259 onError: _onError); | 259 onError: _onError); |
| 260 } else { | 260 } else { |
| 261 close(); | 261 close(); |
| 262 } | 262 } |
| 263 } | 263 } |
| 264 } | 264 } |
| 265 | 265 |
| 266 | 266 |
| OLD | NEW |