Beanz/pdf.js
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #19136 from Snuffleupagus/WorkerMessageHandler-this

Browse Source 
Shorten the `WorkerMessageHandler` class a little bit
This commit is contained in:
Tim van der Meij 2024-12-01 14:40:38 +01:00 committed by GitHub
commit 9f90bc9114
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 18 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
src/core/worker.js
View File

@ -70,9 +70,23 @@ class WorkerTask {
} }
class WorkerMessageHandler { class WorkerMessageHandler {
static {
// Worker thread (and not Node.js)?
if (
typeof window === "undefined" &&
!isNodeJS &&
typeof self !== "undefined" &&
/* isMessagePort = */
typeof self.postMessage === "function" &&
"onmessage" in self
) {
this.initializeFromPort(self);
}
}
static setup(handler, port) { static setup(handler, port) {
let testMessageProcessed = false; let testMessageProcessed = false;
handler.on("test", function (data) { handler.on("test", data => {
if (testMessageProcessed) { if (testMessageProcessed) {
return; // we already processed 'test' message once return; // we already processed 'test' message once
} }
@ -82,13 +96,11 @@ class WorkerMessageHandler {
handler.send("test", data instanceof Uint8Array); handler.send("test", data instanceof Uint8Array);
}); });
handler.on("configure", function (data) { handler.on("configure", data => {
setVerbosityLevel(data.verbosity); setVerbosityLevel(data.verbosity);
}); });
handler.on("GetDocRequest", function (data) { handler.on("GetDocRequest", data => this.createDocumentHandler(data, port));
return WorkerMessageHandler.createDocumentHandler(data, port);
});
} }
static createDocumentHandler(docParams, port) { static createDocumentHandler(docParams, port) {
@ -879,25 +891,9 @@ class WorkerMessageHandler {
static initializeFromPort(port) { static initializeFromPort(port) {
const handler = new MessageHandler("worker", "main", port); const handler = new MessageHandler("worker", "main", port);
WorkerMessageHandler.setup(handler, port); this.setup(handler, port);
handler.send("ready", null); handler.send("ready", null);
} }
} }
function isMessagePort(maybePort) {
return (
typeof maybePort.postMessage === "function" && "onmessage" in maybePort
);
}
// Worker thread (and not Node.js)?
if (
typeof window === "undefined" &&
!isNodeJS &&
typeof self !== "undefined" &&
isMessagePort(self)
) {
WorkerMessageHandler.initializeFromPort(self);
}
export { WorkerMessageHandler, WorkerTask }; export { WorkerMessageHandler, WorkerTask };