| Index: mojo/edk/js/tests/connection_tests.js
|
| diff --git a/mojo/edk/js/tests/connection_tests.js b/mojo/edk/js/tests/connection_tests.js
|
| deleted file mode 100644
|
| index 2e8fc97f23c423b7645f0cfc807b0ce89482100f..0000000000000000000000000000000000000000
|
| --- a/mojo/edk/js/tests/connection_tests.js
|
| +++ /dev/null
|
| @@ -1,135 +0,0 @@
|
| -// Copyright 2013 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.
|
| -
|
| -define([
|
| - "gin/test/expect",
|
| - "mojo/public/js/bindings",
|
| - "mojo/public/js/core",
|
| - "mojo/public/interfaces/bindings/tests/sample_interfaces.mojom",
|
| - "mojo/public/interfaces/bindings/tests/sample_service.mojom",
|
| - "mojo/public/js/threading",
|
| - "gc",
|
| -], function(expect,
|
| - bindings,
|
| - core,
|
| - sample_interfaces,
|
| - sample_service,
|
| - threading,
|
| - gc) {
|
| - testClientServer()
|
| - .then(testWriteToClosedPipe)
|
| - .then(testRequestResponse)
|
| - .then(function() {
|
| - this.result = "PASS";
|
| - gc.collectGarbage(); // should not crash
|
| - threading.quit();
|
| - }.bind(this)).catch(function(e) {
|
| - this.result = "FAIL: " + (e.stack || e);
|
| - threading.quit();
|
| - }.bind(this));
|
| -
|
| - function testClientServer() {
|
| - // ServiceImpl ------------------------------------------------------------
|
| -
|
| - function ServiceImpl() {
|
| - }
|
| -
|
| - ServiceImpl.prototype.frobinate = function(foo, baz, port) {
|
| - expect(foo.name).toBe("Example name");
|
| - expect(baz).toBe(sample_service.Service.BazOptions.REGULAR);
|
| - expect(port.ptr.isBound()).toBeTruthy();
|
| - port.ptr.reset();
|
| -
|
| - return Promise.resolve({result: 42});
|
| - };
|
| -
|
| - var service = new sample_service.ServicePtr();
|
| - var serviceBinding = new bindings.Binding(sample_service.Service,
|
| - new ServiceImpl(),
|
| - bindings.makeRequest(service));
|
| - var sourcePipe = core.createMessagePipe();
|
| - var port = new sample_service.PortPtr();
|
| - var portRequest = bindings.makeRequest(port);
|
| -
|
| - var foo = new sample_service.Foo();
|
| - foo.bar = new sample_service.Bar();
|
| - foo.name = "Example name";
|
| - foo.source = sourcePipe.handle0;
|
| - var promise = service.frobinate(
|
| - foo, sample_service.Service.BazOptions.REGULAR, port)
|
| - .then(function(response) {
|
| - expect(response.result).toBe(42);
|
| -
|
| - service.ptr.reset();
|
| - serviceBinding.close();
|
| -
|
| - return Promise.resolve();
|
| - });
|
| -
|
| - // sourcePipe.handle1 hasn't been closed yet.
|
| - expect(core.close(sourcePipe.handle1)).toBe(core.RESULT_OK);
|
| -
|
| - // portRequest.handle hasn't been closed yet.
|
| - expect(core.close(portRequest.handle)).toBe(core.RESULT_OK);
|
| -
|
| - return promise;
|
| - }
|
| -
|
| - function testWriteToClosedPipe() {
|
| - var service = new sample_service.ServicePtr();
|
| - // Discard the interface request.
|
| - bindings.makeRequest(service);
|
| -
|
| - var promise = service.frobinate(
|
| - null, sample_service.Service.BazOptions.REGULAR, null)
|
| - .then(function(response) {
|
| - return Promise.reject("Unexpected response");
|
| - }).catch(function(e) {
|
| - // We should observe the closed pipe.
|
| - return Promise.resolve();
|
| - });
|
| -
|
| - return promise;
|
| - }
|
| -
|
| - function testRequestResponse() {
|
| - // ProviderImpl ------------------------------------------------------------
|
| -
|
| - function ProviderImpl() {
|
| - }
|
| -
|
| - ProviderImpl.prototype.echoString = function(a) {
|
| - return Promise.resolve({a: a});
|
| - };
|
| -
|
| - ProviderImpl.prototype.echoStrings = function(a, b) {
|
| - return Promise.resolve({a: a, b: b});
|
| - };
|
| -
|
| - var provider = new sample_interfaces.ProviderPtr();
|
| - var providerBinding = new bindings.Binding(sample_interfaces.Provider,
|
| - new ProviderImpl(),
|
| - bindings.makeRequest(provider));
|
| - var promise = provider.echoString("hello").then(function(response) {
|
| - expect(response.a).toBe("hello");
|
| - return provider.echoStrings("hello", "world");
|
| - }).then(function(response) {
|
| - expect(response.a).toBe("hello");
|
| - expect(response.b).toBe("world");
|
| - // Mock a read failure, expect it to fail.
|
| - core.readMessage = function() {
|
| - return { result: core.RESULT_UNKNOWN };
|
| - };
|
| - return provider.echoString("goodbye");
|
| - }).then(function() {
|
| - throw Error("Expected echoString to fail.");
|
| - }, function(error) {
|
| - expect(error.message).toBe("Connection error: " + core.RESULT_UNKNOWN);
|
| -
|
| - return Promise.resolve();
|
| - });
|
| -
|
| - return promise;
|
| - }
|
| -});
|
|
|