1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
|
/* Any copyright is dedicated to the Public Domain.
http://creativecommons.org/publicdomain/zero/1.0/ */
"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 ***/
const { Actor } = require("resource://devtools/shared/protocol/Actor.js");
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();
}
});
});
}
|
