Source code
Revision control
Copy as Markdown
Other Tools
Test Info: Warnings
- This test gets skipped with pattern: os == 'android'
- Manifest: devtools/shared/transport/tests/xpcshell/xpcshell.toml
/* Any copyright is dedicated to the Public Domain.
"use strict";
function run_test() {
initTestDevToolsServer();
add_test_bulk_actor();
add_task(async function () {
await test_string_error(socket_transport, json_reply);
await test_string_error(local_transport, json_reply);
DevToolsServer.destroy();
});
run_next_test();
}
/** * Sample Bulk Actor ***/
class TestBulkActor extends Actor {
constructor(conn) {
super(conn);
this.typeName = "testBulk";
this.requestTypes = {
jsonReply: this.jsonReply,
};
}
jsonReply({ length }) {
Assert.equal(length, really_long().length);
return {
allDone: true,
};
}
}
function add_test_bulk_actor() {
ActorRegistry.addGlobalActor(
{
constructorName: "TestBulkActor",
constructorFun: TestBulkActor,
},
"testBulk"
);
}
/** * Tests ***/
var test_string_error = async function (transportFactory, onReady) {
const transport = await transportFactory();
const client = new DevToolsClient(transport);
await client.connect();
const response = await client.mainRoot.rootForm;
await onReady(client, response);
client.close();
transport.close();
};
/** * Reply Types ***/
function json_reply(client, response) {
const reallyLong = really_long();
const request = client.startBulkRequest({
actor: response.testBulk,
type: "jsonReply",
length: reallyLong.length,
});
// Send bulk data to server
return new Promise(resolve => {
request.on("bulk-send-ready", ({ writer, done }) => {
const input = Cc["@mozilla.org/io/string-input-stream;1"].createInstance(
Ci.nsIStringInputStream
);
input.setData(reallyLong, reallyLong.length);
try {
writer.copyFrom(input, () => {
input.close();
done();
});
do_throw(new Error("Copying should fail, the stream is not async."));
} catch (e) {
Assert.ok(true);
resolve();
}
});
});
}