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

Side by Side Diff: services/dart/test/pingpong_target/main.dart

Issue 982673002: Dart: Removes need to call listen(). (Closed) Base URL: git@github.com:domokit/mojo.git@master
Patch Set: Merge and Format Created 5 years, 9 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 unified diff | Download patch
« no previous file with comments | « services/dart/test/pingpong/main.dart ('k') | no next file » | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright 2015 The Chromium Authors. All rights reserved. 1 // Copyright 2015 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 import 'dart:async'; 5 import 'dart:async';
6 import 'mojo:application'; 6 import 'mojo:application';
7 import 'mojo:bindings'; 7 import 'mojo:bindings';
8 import 'mojo:core'; 8 import 'mojo:core';
9 9
10 import 'package:services/dart/test/pingpong_service.mojom.dart'; 10 import 'package:services/dart/test/pingpong_service.mojom.dart';
11 11
12 class PingPongServiceImpl implements PingPongService { 12 class PingPongServiceImpl implements PingPongService {
13 PingPongServiceStub _stub; 13 PingPongServiceStub _stub;
14 Application _application; 14 Application _application;
15 PingPongClientProxy _pingPongClient; 15 PingPongClientProxy _pingPongClient;
16 16
17 PingPongServiceImpl(Application application, MojoMessagePipeEndpoint endpoint) 17 PingPongServiceImpl(this._application, MojoMessagePipeEndpoint endpoint) {
18 : _application = application { 18 _stub = new PingPongServiceStub.fromEndpoint(endpoint, this);
19 _stub = new PingPongServiceStub.fromEndpoint(endpoint, impl: this);
20 } 19 }
21 20
22 void setClient(ProxyBase proxyBase) { 21 void setClient(ProxyBase proxyBase) {
23 assert(_pingPongClient == null); 22 assert(_pingPongClient == null);
24 _pingPongClient = proxyBase; 23 _pingPongClient = proxyBase;
25 } 24 }
26 25
27 void ping(int pingValue) => _pingPongClient.ptr.pong(pingValue + 1); 26 void ping(int pingValue) => _pingPongClient.ptr.pong(pingValue + 1);
28 27
29 void quit() { 28 void quit() {
30 if (_pingPongClient != null) { 29 if (_pingPongClient != null) {
31 _pingPongClient.close(); 30 _pingPongClient.close();
32 _pingPongClient = null; 31 _pingPongClient = null;
33 } 32 }
34 _stub.close(); 33 _stub.close();
35 } 34 }
36 } 35 }
37 36
38 class PingPongApplication extends Application { 37 class PingPongApplication extends Application {
39 PingPongApplication.fromHandle(MojoHandle handle) : super.fromHandle(handle); 38 PingPongApplication.fromHandle(MojoHandle handle) : super.fromHandle(handle);
40 39
41 @override 40 @override
42 void acceptConnection(String requestorUrl, String resolvedUrl, 41 void acceptConnection(String requestorUrl, String resolvedUrl,
43 ApplicationConnection connection) { 42 ApplicationConnection connection) {
44 connection.provideService( 43 connection.provideService(PingPongServiceName,
45 PingPongServiceName,
46 (endpoint) => new PingPongServiceImpl(this, endpoint)); 44 (endpoint) => new PingPongServiceImpl(this, endpoint));
47 // Close the application when the first connection goes down. 45 // Close the application when the first connection goes down.
48 connection.listen(onClosed: close); 46 connection.onError = close;
49 } 47 }
50 } 48 }
51 49
52 main(List args) { 50 main(List args) {
53 MojoHandle appHandle = new MojoHandle(args[0]); 51 MojoHandle appHandle = new MojoHandle(args[0]);
54 String url = args[1]; 52 String url = args[1];
55 new PingPongApplication.fromHandle(appHandle); 53 new PingPongApplication.fromHandle(appHandle);
56 } 54 }
OLDNEW
« no previous file with comments | « services/dart/test/pingpong/main.dart ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698