suzanne.soy/fork-openpgpjs
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Zero-copy transfer buffers when passing streams to workers

Browse Source
This commit is contained in:
Daniel Huigens 2019-01-04 17:23:22 +01:00
parent 625c6ea4b3
commit fe69cb882d
2 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/util.js
View File

@ -79,8 +79,12 @@ export default {
const reader = stream.getReader(readable);
const { port1, port2 } = new MessageChannel();
port1.onmessage = async function({ data: { action } }) {
if (action === 'read') port1.postMessage(await reader.read());
else if (action === 'cancel') port1.postMessage(await transformed.cancel());
if (action === 'read') {
const result = await reader.read();
port1.postMessage(result, util.getTransferables(result, true));
} else if (action === 'cancel') {
port1.postMessage(await transformed.cancel());
}
};
obj[key] = port2;
collection.push(port2);

2
test/general/openpgp.js
View File

@ -1741,7 +1741,7 @@ describe('[Sauce Labs Group 2] OpenPGP.js public api tests', function() {
if (i++ < 4) {
let randomBytes = await openpgp.crypto.random.getRandomBytes(10);
controller.enqueue(randomBytes);
plaintext.push(randomBytes);
plaintext.push(randomBytes.slice());
} else {
controller.close();
}