Index: mojo/dart/embedder/test/dart_to_cpp_tests.dart |
diff --git a/mojo/dart/embedder/test/dart_to_cpp_tests.dart b/mojo/dart/embedder/test/dart_to_cpp_tests.dart |
index df169578fba14e28a40fd430540ef7432cd8bace..0f364006fc5963332c7797c558a72332f0a83d0f 100644 |
--- a/mojo/dart/embedder/test/dart_to_cpp_tests.dart |
+++ b/mojo/dart/embedder/test/dart_to_cpp_tests.dart |
@@ -9,19 +9,22 @@ import 'mojo:core' as core; |
import 'package:mojo/dart/embedder/test/dart_to_cpp.mojom.dart'; |
-class DartSideImpl extends DartSide { |
+class DartSideImpl implements DartSide { |
static const int BAD_VALUE = 13; |
static const int ELEMENT_BYTES = 1; |
static const int CAPACITY_BYTES = 64; |
+ DartSideStub _stub; |
CppSideProxy cppSide; |
Uint8List _sampleData; |
Uint8List _sampleMessage; |
Completer _completer; |
- DartSideImpl(core.MojoMessagePipeEndpoint endpoint) : super(endpoint) { |
- super.delegate = this; |
+ DartSideImpl(core.MojoMessagePipeEndpoint endpoint) { |
+ _stub = new DartSideStub.fromEndpoint(endpoint) |
+ ..delegate = this |
+ ..listen(); |
_sampleData = new Uint8List(CAPACITY_BYTES); |
for (int i = 0; i < _sampleData.length; ++i) { |
_sampleData[i] = i; |
@@ -42,16 +45,16 @@ class DartSideImpl extends DartSide { |
}); |
} |
- void setClient(CppSideProxy proxy) { |
+ void setClient(bindings.ProxyBase proxy) { |
assert(cppSide == null); |
cppSide = proxy; |
- cppSide.startTest(); |
+ cppSide.interface.startTest(); |
} |
void ping() { |
- cppSide.pingResponse(); |
+ cppSide.interface.pingResponse(); |
_completer.complete(null); |
- cppSide.close(); |
+ cppSide.impl.close(); |
} |
void echo(int numIterations, EchoArgs arg) { |
@@ -91,16 +94,16 @@ class DartSideImpl extends DartSide { |
messagePipe1.endpoints[1].write(_sampleMessage.buffer.asByteData()); |
messagePipe2.endpoints[1].write(_sampleMessage.buffer.asByteData()); |
- cppSide.echoResponse(createEchoArgsList([arg, specialArg])); |
+ cppSide.interface.echoResponse(createEchoArgsList([arg, specialArg])); |
dataPipe1.producer.handle.close(); |
dataPipe2.producer.handle.close(); |
messagePipe1.endpoints[1].handle.close(); |
messagePipe2.endpoints[1].handle.close(); |
} |
- cppSide.testFinished(); |
+ cppSide.interface.testFinished(); |
_completer.complete(null); |
- cppSide.close(); |
+ cppSide.impl.close(); |
} |
Future<bool> get future => _completer.future; |
@@ -113,7 +116,6 @@ main(List args) { |
var rawHandle = new core.MojoHandle(mojoHandle); |
var endpoint = new core.MojoMessagePipeEndpoint(rawHandle); |
var dartSide = new DartSideImpl(endpoint); |
- dartSide.listen(); |
dartSide.future.then((_) { |
print('Success'); |
}); |