blob: ba6e2b43ba8e073c3326a3c6f55a6f2b3f7ab685 [file] [log] [blame]
// Copyright 2015 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
import 'dart:async';
import 'dart:mojo_application';
import 'dart:mojo_bindings';
import 'dart:mojo_core';
import 'package:services/dart/test/pingpong_service.mojom.dart';
class PingPongServiceImpl extends PingPongService {
Application _application;
PingPongClientProxy _proxy;
PingPongServiceImpl(Application application, MojoMessagePipeEndpoint endpoint)
: _application = application, super(endpoint) {
super.delegate = this;
}
void setClient(PingPongClientProxy proxy) {
assert(_proxy == null);
_proxy = proxy;
}
void ping(int pingValue) => _proxy.pong(pingValue + 1);
void quit() {
if (_proxy != null) {
_proxy.close();
}
super.close();
if (_application != null) {
_application.close();
}
}
}
class PingPongApplication extends Application {
PingPongApplication.fromHandle(MojoHandle handle) : super.fromHandle(handle);
void acceptConnection(String requestorUrl, ApplicationConnection connection) {
connection.provideService(PingPongService.name,
(endpoint) => new PingPongServiceImpl(this, endpoint));
connection.listen();
}
}
main(List args) {
MojoHandle appHandle = new MojoHandle(args[0]);
String url = args[1];
var pingPongApplication = new PingPongApplication.fromHandle(appHandle);
pingPongApplication.listen();
}