Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(104)

Unified Diff: mojo/dart/embedder/io/server_socket_patch.dart

Issue 2006093002: Dart: Futures -> Callbacks. (Closed) Base URL: git@github.com:domokit/mojo.git@master
Patch Set: Merge Created 4 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « mojo/dart/embedder/io/mojo_patch.dart ('k') | mojo/dart/embedder/io/socket_patch.dart » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: mojo/dart/embedder/io/server_socket_patch.dart
diff --git a/mojo/dart/embedder/io/server_socket_patch.dart b/mojo/dart/embedder/io/server_socket_patch.dart
index fd5fea80cec5b99e8a72e6cab9cccf25e83d8d04..4ec4b7a532ad16863108a8b0d03d065a0dac0b0d 100644
--- a/mojo/dart/embedder/io/server_socket_patch.dart
+++ b/mojo/dart/embedder/io/server_socket_patch.dart
@@ -28,8 +28,8 @@ patch class ServerSocket {
class _MojoRawServerSocket extends Stream<RawSocket>
implements RawServerSocket {
- final _tcpBoundSocket = new TcpBoundSocketProxy.unbound();
- final _tcpServerSocket = new TcpServerSocketProxy.unbound();
+ final _tcpBoundSocket = new _TcpBoundSocketProxy.unbound();
+ final _tcpServerSocket = new _TcpServerSocketProxy.unbound();
final bool _v6Only;
InternetAddress _boundAddress;
int _boundPort;
@@ -50,7 +50,7 @@ class _MojoRawServerSocket extends Stream<RawSocket>
var response =
await networkService.createTcpBoundSocket(
bindAddress,
- rawServerSocket._tcpBoundSocket);
+ rawServerSocket._tcpBoundSocket.proxy);
if (!_NetworkService._okay(response.result)) {
rawServerSocket.close();
_NetworkService._throwOnError(response.result);
@@ -60,8 +60,8 @@ class _MojoRawServerSocket extends Stream<RawSocket>
rawServerSocket._boundPort =
_NetworkServiceCodec._portFromNetAddress(response.boundTo);
final boundSocket = rawServerSocket._tcpBoundSocket;
- response =
- await boundSocket.startListening(rawServerSocket._tcpServerSocket);
+ response = await boundSocket.startListening(
+ rawServerSocket._tcpServerSocket.proxy);
if (!_NetworkService._okay(response.result)) {
rawServerSocket.close();
_NetworkService._throwOnError(response.result);
« no previous file with comments | « mojo/dart/embedder/io/mojo_patch.dart ('k') | mojo/dart/embedder/io/socket_patch.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698