@loaders.gl/worker-utils - npm Package Compare versions

Comparing version 3.0.0-alpha.18 to 3.0.0-alpha.19

dist/es5/index.js

@@ -8,2 +8,26 @@ "use strict";
 });
+Object.defineProperty(exports, "WorkerObject", {
+  enumerable: true,
+  get: function get() {
+    return _types.WorkerObject;
+  }
+});
+Object.defineProperty(exports, "WorkerMessage", {
+  enumerable: true,
+  get: function get() {
+    return _protocol.WorkerMessage;
+  }
+});
+Object.defineProperty(exports, "WorkerMessageData", {
+  enumerable: true,
+  get: function get() {
+    return _protocol.WorkerMessageData;
+  }
+});
+Object.defineProperty(exports, "WorkerMessagePayload", {
+  enumerable: true,
+  get: function get() {
+    return _protocol.WorkerMessagePayload;
+  }
+});
 Object.defineProperty(exports, "assert", {
@@ -27,2 +51,14 @@ enumerable: true,
 });
+Object.defineProperty(exports, "WorkerJob", {
+  enumerable: true,
+  get: function get() {
+    return _workerJob.default;
+  }
+});
+Object.defineProperty(exports, "WorkerThread", {
+  enumerable: true,
+  get: function get() {
+    return _workerThread.default;
+  }
+});
 Object.defineProperty(exports, "processOnWorker", {
@@ -82,12 +118,12 @@ enumerable: true,
 });
-Object.defineProperty(exports, "ChildProcessProxy", {
+Object.defineProperty(exports, "AsyncQueue", {
   enumerable: true,
   get: function get() {
-    return _childProcessProxy.default;
+    return _asyncQueue.default;
   }
 });
-Object.defineProperty(exports, "AsyncQueue", {
+Object.defineProperty(exports, "ChildProcessProxy", {
   enumerable: true,
   get: function get() {
-    return _asyncQueue.default;
+    return _childProcessProxy.default;
   }
@@ -97,2 +133,6 @@ });
 
+var _types = require("./types");
+
+var _protocol = require("./lib/worker-protocol/protocol");
+
 var _assert = require("./lib/env-utils/assert");
@@ -102,2 +142,6 @@
 
+var _workerJob = _interopRequireDefault(require("./lib/worker-farm/worker-job"));
+
+var _workerThread = _interopRequireDefault(require("./lib/worker-farm/worker-thread"));
+
 var _processOnWorker = require("./lib/worker-api/process-on-worker");
@@ -117,7 +161,7 @@
 
+var _asyncQueue = _interopRequireDefault(require("./lib/async-queue/async-queue"));
+
 var _childProcessProxy = _interopRequireDefault(require("./lib/process-utils/child-process-proxy"));
 
-var _asyncQueue = _interopRequireDefault(require("./lib/async-queue/async-queue"));
-
-var VERSION = typeof "3.0.0-alpha.18" !== 'undefined' ? "3.0.0-alpha.18" : 'latest';
+var VERSION = typeof "3.0.0-alpha.19" !== 'undefined' ? "3.0.0-alpha.19" : 'latest';
 var NullWorker = {
@@ -124,0 +168,0 @@ id: 'null',

dist/es5/lib/async-queue/async-queue.d.ts

@@ -19,3 +19,3 @@ /**
   /** @returns a Promise for an IteratorResult */
-  next(): Promise<{done: boolean, value?: T}>;
+  next(): Promise<{done: boolean; value?: T}>;
 
@@ -22,0 +22,0 @@ /** Push a new value - the async iterator will yield a promise resolved to this value */

dist/es5/lib/library-utils/library-utils.d.ts

@@ -16,3 +16,7 @@ /**
  */
-export function loadLibrary(libraryUrl: string, moduleName?: string, options?: object): Promise<any>;
+export function loadLibrary(
+  libraryUrl: string,
+  moduleName?: string,
+  options?: object
+): Promise<any>;
 export function getLibraryUrl(library, moduleName?: string, options?): string;

dist/es5/lib/library-utils/library-utils.js

 "use strict";
 
-var _interopRequireWildcard = require("@babel/runtime/helpers/interopRequireWildcard");
-
 var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
 
+var _typeof = require("@babel/runtime/helpers/typeof");
+
 Object.defineProperty(exports, "__esModule", {
@@ -23,4 +23,8 @@ value: true
 
+function _getRequireWildcardCache(nodeInterop) { if (typeof WeakMap !== "function") return null; var cacheBabelInterop = new WeakMap(); var cacheNodeInterop = new WeakMap(); return (_getRequireWildcardCache = function _getRequireWildcardCache(nodeInterop) { return nodeInterop ? cacheNodeInterop : cacheBabelInterop; })(nodeInterop); }
+
+function _interopRequireWildcard(obj, nodeInterop) { if (!nodeInterop && obj && obj.__esModule) { return obj; } if (obj === null || _typeof(obj) !== "object" && typeof obj !== "function") { return { default: obj }; } var cache = _getRequireWildcardCache(nodeInterop); if (cache && cache.has(obj)) { return cache.get(obj); } var newObj = {}; var hasPropertyDescriptor = Object.defineProperty && Object.getOwnPropertyDescriptor; for (var key in obj) { if (key !== "default" && Object.prototype.hasOwnProperty.call(obj, key)) { var desc = hasPropertyDescriptor ? Object.getOwnPropertyDescriptor(obj, key) : null; if (desc && (desc.get || desc.set)) { Object.defineProperty(newObj, key, desc); } else { newObj[key] = obj[key]; } } } newObj.default = obj; if (cache) { cache.set(obj, newObj); } return newObj; }
+
 var LATEST = 'beta';
-var VERSION = typeof "3.0.0-alpha.18" !== 'undefined' ? "3.0.0-alpha.18" : LATEST;
+var VERSION = typeof "3.0.0-alpha.19" !== 'undefined' ? "3.0.0-alpha.19" : LATEST;
 var loadLibraryPromises = {};
@@ -27,0 +31,0 @@

dist/es5/lib/node/require-utils.node.js

@@ -23,3 +23,3 @@ "use strict";
 
-function ownKeys(object, enumerableOnly) { var keys = Object.keys(object); if (Object.getOwnPropertySymbols) { var symbols = Object.getOwnPropertySymbols(object); if (enumerableOnly) symbols = symbols.filter(function (sym) { return Object.getOwnPropertyDescriptor(object, sym).enumerable; }); keys.push.apply(keys, symbols); } return keys; }
+function ownKeys(object, enumerableOnly) { var keys = Object.keys(object); if (Object.getOwnPropertySymbols) { var symbols = Object.getOwnPropertySymbols(object); if (enumerableOnly) { symbols = symbols.filter(function (sym) { return Object.getOwnPropertyDescriptor(object, sym).enumerable; }); } keys.push.apply(keys, symbols); } return keys; }
 
@@ -26,0 +26,0 @@ function _objectSpread(target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i] != null ? arguments[i] : {}; if (i % 2) { ownKeys(Object(source), true).forEach(function (key) { (0, _defineProperty2.default)(target, key, source[key]); }); } else if (Object.getOwnPropertyDescriptors) { Object.defineProperties(target, Object.getOwnPropertyDescriptors(source)); } else { ownKeys(Object(source)).forEach(function (key) { Object.defineProperty(target, key, Object.getOwnPropertyDescriptor(source, key)); }); } } return target; }

dist/es5/lib/process-utils/child-process-proxy.d.ts

@@ -5,16 +5,16 @@ import ChildProcess from 'child_process';
   command: string;
-  arguments: string[],
+  arguments: string[];
   /** Whether to add a port specified arg */
-  portArg?: string,
+  portArg?: string;
   /** Base port number */
-  port?: number,
+  port?: number;
   /** Whether to search for an available port if the base port is occupied */
-  autoPort?: boolean,
+  autoPort?: boolean;
   /** Number of milliseconds to wait until concluding success */
   /** wait: 0 - infinity */
-  wait?: number,
+  wait?: number;
   /** Options passed on to Node'.js `ChildProcess.spawn` */
-  spawn?: ChildProcess.SpawnOptionsWithoutStdio,
+  spawn?: ChildProcess.SpawnOptionsWithoutStdio;
   /** Callback when the  */
-  onStart?: (proxy: ChildProcessProxy) => void
+  onStart?: (proxy: ChildProcessProxy) => void;
 };
@@ -33,3 +33,3 @@
   /** Stops a running child process */
-  stop(): Promise<void>
+  stop(): Promise<void>;
 
@@ -36,0 +36,0 @@ /** Exits this process */

dist/es5/lib/process-utils/child-process-proxy.js

@@ -28,3 +28,3 @@ "use strict";
 
-function ownKeys(object, enumerableOnly) { var keys = Object.keys(object); if (Object.getOwnPropertySymbols) { var symbols = Object.getOwnPropertySymbols(object); if (enumerableOnly) symbols = symbols.filter(function (sym) { return Object.getOwnPropertyDescriptor(object, sym).enumerable; }); keys.push.apply(keys, symbols); } return keys; }
+function ownKeys(object, enumerableOnly) { var keys = Object.keys(object); if (Object.getOwnPropertySymbols) { var symbols = Object.getOwnPropertySymbols(object); if (enumerableOnly) { symbols = symbols.filter(function (sym) { return Object.getOwnPropertyDescriptor(object, sym).enumerable; }); } keys.push.apply(keys, symbols); } return keys; }
 
@@ -31,0 +31,0 @@ function _objectSpread(target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i] != null ? arguments[i] : {}; if (i % 2) { ownKeys(Object(source), true).forEach(function (key) { (0, _defineProperty2.default)(target, key, source[key]); }); } else if (Object.getOwnPropertyDescriptors) { Object.defineProperties(target, Object.getOwnPropertyDescriptors(source)); } else { ownKeys(Object(source)).forEach(function (key) { Object.defineProperty(target, key, Object.getOwnPropertyDescriptor(source, key)); }); } } return target; }

dist/es5/lib/worker-api/create-worker.d.ts

@@ -6,5 +6,2 @@ type ProcessFunction = (data: any, options: {[key: string]: any}) => Promise<any>;
  */
-export function createWorker(
-  process: ProcessFunction,
-  processInBatches?: Function,
-): void;
+export function createWorker(process: ProcessFunction, processInBatches?: Function): void;

dist/es5/lib/worker-api/process-on-worker.d.ts

@@ -7,6 +7,2 @@ import {WorkerObject} from '../../types';
  */
-export function processOnWorker(
-  worker: WorkerObject,
-  data: any,
-  options?: object
-): Promise<any>;
+export function processOnWorker(worker: WorkerObject, data: any, options?: object): Promise<any>;

dist/es5/lib/worker-api/worker-object-utils.d.ts

@@ -10,3 +10,3 @@ import {WorkerObject} from '../../types';
  */
-export function getWorkerObjectURL(worker: WorkerObject, options: object): string
+export function getWorkerObjectURL(worker: WorkerObject, options: object): string;
 
@@ -30,4 +30,4 @@ /**
  * Safely stringify JSON (drop non serializable values like functions and regexps)
- * @param value 
+ * @param value
  */
 export function removeNontransferableOptions(object: object): object;

dist/es5/lib/worker-api/worker-object-utils.js

@@ -18,3 +18,3 @@ "use strict";
 var NPM_TAG = 'beta';
-var VERSION = typeof "3.0.0-alpha.18" !== 'undefined' ? "3.0.0-alpha.18" : NPM_TAG;
+var VERSION = typeof "3.0.0-alpha.19" !== 'undefined' ? "3.0.0-alpha.19" : NPM_TAG;
 
@@ -21,0 +21,0 @@ function getWorkerObjectURL(worker, options) {

dist/es5/lib/worker-farm/get-transfer-list.d.ts

@@ -1,2 +0,1 @@
-
 /**
@@ -10,2 +9,6 @@ * Returns an array of Transferrable objects that can be used with postMessage
  */
-export function getTransferList(object: any, recursive?: boolean, transfers?: Set<any>): Transferable[];
+export function getTransferList(
+  object: any,
+  recursive?: boolean,
+  transfers?: Set<any>
+): Transferable[];

dist/es5/lib/worker-farm/worker-body.d.ts

@@ -16,4 +16,8 @@ import {WorkerMessageType, WorkerMessagePayload} from '../worker-protocol/protocol';
 
-  static addEventListener(onMessage: (type: WorkerMessageType, payload: WorkerMessagePayload) => any);
-  static removeEventListener(onMessage: (type: WorkerMessageType, payload: WorkerMessagePayload) => any);
+  static addEventListener(
+    onMessage: (type: WorkerMessageType, payload: WorkerMessagePayload) => any
+  );
+  static removeEventListener(
+    onMessage: (type: WorkerMessageType, payload: WorkerMessagePayload) => any
+  );
 }

dist/es5/lib/worker-farm/worker-farm.d.ts

@@ -11,3 +11,3 @@ import {WorkerPool} from '../..';
   onDebug?: () => void;
-}
+};
 
@@ -49,3 +49,3 @@ /**
    */
-  getWorkerPool(options: {name: string, source?: string, url?: string}): WorkerPool;
+  getWorkerPool(options: {name: string; source?: string; url?: string}): WorkerPool;
 }

dist/es5/lib/worker-farm/worker-farm.js

@@ -22,3 +22,3 @@ "use strict";
 
-function ownKeys(object, enumerableOnly) { var keys = Object.keys(object); if (Object.getOwnPropertySymbols) { var symbols = Object.getOwnPropertySymbols(object); if (enumerableOnly) symbols = symbols.filter(function (sym) { return Object.getOwnPropertyDescriptor(object, sym).enumerable; }); keys.push.apply(keys, symbols); } return keys; }
+function ownKeys(object, enumerableOnly) { var keys = Object.keys(object); if (Object.getOwnPropertySymbols) { var symbols = Object.getOwnPropertySymbols(object); if (enumerableOnly) { symbols = symbols.filter(function (sym) { return Object.getOwnPropertyDescriptor(object, sym).enumerable; }); } keys.push.apply(keys, symbols); } return keys; }
 
@@ -25,0 +25,0 @@ function _objectSpread(target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i] != null ? arguments[i] : {}; if (i % 2) { ownKeys(Object(source), true).forEach(function (key) { (0, _defineProperty2.default)(target, key, source[key]); }); } else if (Object.getOwnPropertyDescriptors) { Object.defineProperties(target, Object.getOwnPropertyDescriptors(source)); } else { ownKeys(Object(source)).forEach(function (key) { Object.defineProperty(target, key, Object.getOwnPropertyDescriptor(source, key)); }); } } return target; }

dist/es5/lib/worker-farm/worker-pool.d.ts

@@ -26,3 +26,3 @@ import WorkerJob from './worker-job';
     onDebug?: (options: OnDebugParameters) => any;
-    reuseWorkers?: boolean
+    reuseWorkers?: boolean;
   });
@@ -29,0 +29,0 @@

dist/es5/lib/worker-farm/worker-thread.d.ts

@@ -1,2 +0,1 @@
-
 export type WorkerThreadProps = {
@@ -6,3 +5,3 @@ name: string;
   url?: string;
-}
+};
 
@@ -9,0 +8,0 @@ /**

dist/esm/index.js

@@ -0,3 +1,7 @@
+export { WorkerObject } from './types';
+export { WorkerMessage, WorkerMessageData, WorkerMessagePayload } from './lib/worker-protocol/protocol';
 export { assert } from './lib/env-utils/assert';
 export { isBrowser, isWorker } from './lib/env-utils/globals';
+export { default as WorkerJob } from './lib/worker-farm/worker-job';
+export { default as WorkerThread } from './lib/worker-farm/worker-thread';
 export { processOnWorker } from './lib/worker-api/process-on-worker';
@@ -10,5 +14,5 @@ export { createWorker } from './lib/worker-api/create-worker';
 export { getLibraryUrl, loadLibrary } from './lib/library-utils/library-utils';
+export { default as AsyncQueue } from './lib/async-queue/async-queue';
 export { default as ChildProcessProxy } from './lib/process-utils/child-process-proxy';
-export { default as AsyncQueue } from './lib/async-queue/async-queue';
-var VERSION = typeof "3.0.0-alpha.18" !== 'undefined' ? "3.0.0-alpha.18" : 'latest';
+var VERSION = typeof "3.0.0-alpha.19" !== 'undefined' ? "3.0.0-alpha.19" : 'latest';
 export var NullWorker = {
@@ -15,0 +19,0 @@ id: 'null',

dist/esm/lib/async-queue/async-queue.d.ts

@@ -19,3 +19,3 @@ /**
   /** @returns a Promise for an IteratorResult */
-  next(): Promise<{done: boolean, value?: T}>;
+  next(): Promise<{done: boolean; value?: T}>;
 
@@ -22,0 +22,0 @@ /** Push a new value - the async iterator will yield a promise resolved to this value */

dist/esm/lib/library-utils/library-utils.d.ts

@@ -16,3 +16,7 @@ /**
  */
-export function loadLibrary(libraryUrl: string, moduleName?: string, options?: object): Promise<any>;
+export function loadLibrary(
+  libraryUrl: string,
+  moduleName?: string,
+  options?: object
+): Promise<any>;
 export function getLibraryUrl(library, moduleName?: string, options?): string;

dist/esm/lib/library-utils/library-utils.js

@@ -7,3 +7,3 @@ import _asyncToGenerator from "@babel/runtime/helpers/esm/asyncToGenerator";
 var LATEST = 'beta';
-var VERSION = typeof "3.0.0-alpha.18" !== 'undefined' ? "3.0.0-alpha.18" : LATEST;
+var VERSION = typeof "3.0.0-alpha.19" !== 'undefined' ? "3.0.0-alpha.19" : LATEST;
 var loadLibraryPromises = {};
@@ -10,0 +10,0 @@ export function loadLibrary(_x) {

dist/esm/lib/node/require-utils.node.js

@@ -6,3 +6,3 @@ import _defineProperty from "@babel/runtime/helpers/esm/defineProperty";
 
-function ownKeys(object, enumerableOnly) { var keys = Object.keys(object); if (Object.getOwnPropertySymbols) { var symbols = Object.getOwnPropertySymbols(object); if (enumerableOnly) symbols = symbols.filter(function (sym) { return Object.getOwnPropertyDescriptor(object, sym).enumerable; }); keys.push.apply(keys, symbols); } return keys; }
+function ownKeys(object, enumerableOnly) { var keys = Object.keys(object); if (Object.getOwnPropertySymbols) { var symbols = Object.getOwnPropertySymbols(object); if (enumerableOnly) { symbols = symbols.filter(function (sym) { return Object.getOwnPropertyDescriptor(object, sym).enumerable; }); } keys.push.apply(keys, symbols); } return keys; }
 
@@ -9,0 +9,0 @@ function _objectSpread(target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i] != null ? arguments[i] : {}; if (i % 2) { ownKeys(Object(source), true).forEach(function (key) { _defineProperty(target, key, source[key]); }); } else if (Object.getOwnPropertyDescriptors) { Object.defineProperties(target, Object.getOwnPropertyDescriptors(source)); } else { ownKeys(Object(source)).forEach(function (key) { Object.defineProperty(target, key, Object.getOwnPropertyDescriptor(source, key)); }); } } return target; }

dist/esm/lib/process-utils/child-process-proxy.d.ts

@@ -5,16 +5,16 @@ import ChildProcess from 'child_process';
   command: string;
-  arguments: string[],
+  arguments: string[];
   /** Whether to add a port specified arg */
-  portArg?: string,
+  portArg?: string;
   /** Base port number */
-  port?: number,
+  port?: number;
   /** Whether to search for an available port if the base port is occupied */
-  autoPort?: boolean,
+  autoPort?: boolean;
   /** Number of milliseconds to wait until concluding success */
   /** wait: 0 - infinity */
-  wait?: number,
+  wait?: number;
   /** Options passed on to Node'.js `ChildProcess.spawn` */
-  spawn?: ChildProcess.SpawnOptionsWithoutStdio,
+  spawn?: ChildProcess.SpawnOptionsWithoutStdio;
   /** Callback when the  */
-  onStart?: (proxy: ChildProcessProxy) => void
+  onStart?: (proxy: ChildProcessProxy) => void;
 };
@@ -33,3 +33,3 @@
   /** Stops a running child process */
-  stop(): Promise<void>
+  stop(): Promise<void>;
 
@@ -36,0 +36,0 @@ /** Exits this process */

dist/esm/lib/process-utils/child-process-proxy.js

@@ -8,3 +8,3 @@ import _toConsumableArray from "@babel/runtime/helpers/esm/toConsumableArray";
 
-function ownKeys(object, enumerableOnly) { var keys = Object.keys(object); if (Object.getOwnPropertySymbols) { var symbols = Object.getOwnPropertySymbols(object); if (enumerableOnly) symbols = symbols.filter(function (sym) { return Object.getOwnPropertyDescriptor(object, sym).enumerable; }); keys.push.apply(keys, symbols); } return keys; }
+function ownKeys(object, enumerableOnly) { var keys = Object.keys(object); if (Object.getOwnPropertySymbols) { var symbols = Object.getOwnPropertySymbols(object); if (enumerableOnly) { symbols = symbols.filter(function (sym) { return Object.getOwnPropertyDescriptor(object, sym).enumerable; }); } keys.push.apply(keys, symbols); } return keys; }
 
@@ -11,0 +11,0 @@ function _objectSpread(target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i] != null ? arguments[i] : {}; if (i % 2) { ownKeys(Object(source), true).forEach(function (key) { _defineProperty(target, key, source[key]); }); } else if (Object.getOwnPropertyDescriptors) { Object.defineProperties(target, Object.getOwnPropertyDescriptors(source)); } else { ownKeys(Object(source)).forEach(function (key) { Object.defineProperty(target, key, Object.getOwnPropertyDescriptor(source, key)); }); } } return target; }

dist/esm/lib/worker-api/create-worker.d.ts

@@ -6,5 +6,2 @@ type ProcessFunction = (data: any, options: {[key: string]: any}) => Promise<any>;
  */
-export function createWorker(
-  process: ProcessFunction,
-  processInBatches?: Function,
-): void;
+export function createWorker(process: ProcessFunction, processInBatches?: Function): void;

dist/esm/lib/worker-api/process-on-worker.d.ts

@@ -7,6 +7,2 @@ import {WorkerObject} from '../../types';
  */
-export function processOnWorker(
-  worker: WorkerObject,
-  data: any,
-  options?: object
-): Promise<any>;
+export function processOnWorker(worker: WorkerObject, data: any, options?: object): Promise<any>;

dist/esm/lib/worker-api/worker-object-utils.d.ts

@@ -10,3 +10,3 @@ import {WorkerObject} from '../../types';
  */
-export function getWorkerObjectURL(worker: WorkerObject, options: object): string
+export function getWorkerObjectURL(worker: WorkerObject, options: object): string;
 
@@ -30,4 +30,4 @@ /**
  * Safely stringify JSON (drop non serializable values like functions and regexps)
- * @param value 
+ * @param value
  */
 export function removeNontransferableOptions(object: object): object;

dist/esm/lib/worker-api/worker-object-utils.js

 import _typeof from "@babel/runtime/helpers/esm/typeof";
 import { assert } from '../env-utils/assert';
 var NPM_TAG = 'beta';
-var VERSION = typeof "3.0.0-alpha.18" !== 'undefined' ? "3.0.0-alpha.18" : NPM_TAG;
+var VERSION = typeof "3.0.0-alpha.19" !== 'undefined' ? "3.0.0-alpha.19" : NPM_TAG;
 export function getWorkerObjectURL(worker, options) {
@@ -6,0 +6,0 @@ var topOptions = options || {};

dist/esm/lib/worker-farm/get-transfer-list.d.ts

@@ -1,2 +0,1 @@
-
 /**
@@ -10,2 +9,6 @@ * Returns an array of Transferrable objects that can be used with postMessage
  */
-export function getTransferList(object: any, recursive?: boolean, transfers?: Set<any>): Transferable[];
+export function getTransferList(
+  object: any,
+  recursive?: boolean,
+  transfers?: Set<any>
+): Transferable[];

dist/esm/lib/worker-farm/worker-body.d.ts

@@ -16,4 +16,8 @@ import {WorkerMessageType, WorkerMessagePayload} from '../worker-protocol/protocol';
 
-  static addEventListener(onMessage: (type: WorkerMessageType, payload: WorkerMessagePayload) => any);
-  static removeEventListener(onMessage: (type: WorkerMessageType, payload: WorkerMessagePayload) => any);
+  static addEventListener(
+    onMessage: (type: WorkerMessageType, payload: WorkerMessagePayload) => any
+  );
+  static removeEventListener(
+    onMessage: (type: WorkerMessageType, payload: WorkerMessagePayload) => any
+  );
 }

dist/esm/lib/worker-farm/worker-farm.d.ts

@@ -11,3 +11,3 @@ import {WorkerPool} from '../..';
   onDebug?: () => void;
-}
+};
 
@@ -49,3 +49,3 @@ /**
    */
-  getWorkerPool(options: {name: string, source?: string, url?: string}): WorkerPool;
+  getWorkerPool(options: {name: string; source?: string; url?: string}): WorkerPool;
 }

dist/esm/lib/worker-farm/worker-farm.js

@@ -5,3 +5,3 @@ import _defineProperty from "@babel/runtime/helpers/esm/defineProperty";
 
-function ownKeys(object, enumerableOnly) { var keys = Object.keys(object); if (Object.getOwnPropertySymbols) { var symbols = Object.getOwnPropertySymbols(object); if (enumerableOnly) symbols = symbols.filter(function (sym) { return Object.getOwnPropertyDescriptor(object, sym).enumerable; }); keys.push.apply(keys, symbols); } return keys; }
+function ownKeys(object, enumerableOnly) { var keys = Object.keys(object); if (Object.getOwnPropertySymbols) { var symbols = Object.getOwnPropertySymbols(object); if (enumerableOnly) { symbols = symbols.filter(function (sym) { return Object.getOwnPropertyDescriptor(object, sym).enumerable; }); } keys.push.apply(keys, symbols); } return keys; }
 
@@ -8,0 +8,0 @@ function _objectSpread(target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i] != null ? arguments[i] : {}; if (i % 2) { ownKeys(Object(source), true).forEach(function (key) { _defineProperty(target, key, source[key]); }); } else if (Object.getOwnPropertyDescriptors) { Object.defineProperties(target, Object.getOwnPropertyDescriptors(source)); } else { ownKeys(Object(source)).forEach(function (key) { Object.defineProperty(target, key, Object.getOwnPropertyDescriptor(source, key)); }); } } return target; }

dist/esm/lib/worker-farm/worker-pool.d.ts

@@ -26,3 +26,3 @@ import WorkerJob from './worker-job';
     onDebug?: (options: OnDebugParameters) => any;
-    reuseWorkers?: boolean
+    reuseWorkers?: boolean;
   });
@@ -29,0 +29,0 @@

dist/esm/lib/worker-farm/worker-thread.d.ts

@@ -1,2 +0,1 @@
-
 export type WorkerThreadProps = {
@@ -6,3 +5,3 @@ name: string;
   url?: string;
-}
+};
 
@@ -9,0 +8,0 @@ /**

dist/null-worker.js

@@ -212,4 +212,2 @@ /******/ (function(modules) { // webpackBootstrap
 
-/* global self */
-
 /** @typedef {import('../worker-protocol/protocol').WorkerMessageType} WorkerMessageType  */
@@ -300,4 +298,2 @@
 // core does not need all the utils in loader-utils, just this one.
-
-/* global MessagePort, ImageBitmap, OffscreenCanvas */
 // Returns an array of Transferrable objects that can be used with postMessage
@@ -368,4 +364,2 @@ // https://developer.mozilla.org/en-US/docs/Web/API/Worker/postMessage
 
-/* global self */
-
 /** @typedef {import('../worker-protocol/protocol').WorkerMessageData} WorkerMessageData */
@@ -372,0 +366,0 @@

package.json

 {
   "name": "@loaders.gl/worker-utils",
-  "version": "3.0.0-alpha.18",
+  "version": "3.0.0-alpha.19",
   "description": "Utilities for running tasks on worker threads",
@@ -18,3 +18,3 @@ "license": "MIT",
   ],
-  "types": "src/index.d.ts",
+  "types": "src/index.ts",
   "main": "dist/es5/index.js",
@@ -45,3 +45,3 @@ "module": "dist/esm/index.js",
   },
-  "gitHead": "8cb1ea7be6c51bae6a4c61b8ee4b71586b02a797"
+  "gitHead": "4e0a11c8f59a3c3b96eab8e5b81469f72d682e96"
 }

src/lib/async-queue/async-queue.d.ts

@@ -19,3 +19,3 @@ /**
   /** @returns a Promise for an IteratorResult */
-  next(): Promise<{done: boolean, value?: T}>;
+  next(): Promise<{done: boolean; value?: T}>;
 
@@ -22,0 +22,0 @@ /** Push a new value - the async iterator will yield a promise resolved to this value */

src/lib/env-utils/globals.js

@@ -26,3 +26,2 @@ // Copyright (c) 2015 - 2017 Uber Technologies, Inc.
 /* eslint-disable no-restricted-globals */
-/* global process, window, global, document, self, importScripts */
 const globals = {
@@ -29,0 +28,0 @@ self: typeof self !== 'undefined' && self,

src/lib/library-utils/library-utils.d.ts

@@ -16,3 +16,7 @@ /**
  */
-export function loadLibrary(libraryUrl: string, moduleName?: string, options?: object): Promise<any>;
+export function loadLibrary(
+  libraryUrl: string,
+  moduleName?: string,
+  options?: object
+): Promise<any>;
 export function getLibraryUrl(library, moduleName?: string, options?): string;

src/lib/library-utils/library-utils.js

@@ -1,2 +0,1 @@
-/* global fetch, document */
 import {global, isBrowser, isWorker} from '../env-utils/globals';
@@ -70,3 +69,2 @@ import * as node from '../node/require-utils.node';
   if (isWorker) {
-    /* global importScripts */
     return importScripts(libraryUrl);
@@ -73,0 +71,0 @@ }

src/lib/node/require-utils.node.js

@@ -7,3 +7,2 @@ // Fork of https://github.com/floatdrop/require-from-string/blob/master/index.js
 
-/* global process, fetch */
 import Module from 'module';
@@ -10,0 +9,0 @@ import path from 'path';

src/lib/process-utils/child-process-proxy.d.ts

@@ -5,16 +5,16 @@ import ChildProcess from 'child_process';
   command: string;
-  arguments: string[],
+  arguments: string[];
   /** Whether to add a port specified arg */
-  portArg?: string,
+  portArg?: string;
   /** Base port number */
-  port?: number,
+  port?: number;
   /** Whether to search for an available port if the base port is occupied */
-  autoPort?: boolean,
+  autoPort?: boolean;
   /** Number of milliseconds to wait until concluding success */
   /** wait: 0 - infinity */
-  wait?: number,
+  wait?: number;
   /** Options passed on to Node'.js `ChildProcess.spawn` */
-  spawn?: ChildProcess.SpawnOptionsWithoutStdio,
+  spawn?: ChildProcess.SpawnOptionsWithoutStdio;
   /** Callback when the  */
-  onStart?: (proxy: ChildProcessProxy) => void
+  onStart?: (proxy: ChildProcessProxy) => void;
 };
@@ -33,3 +33,3 @@
   /** Stops a running child process */
-  stop(): Promise<void>
+  stop(): Promise<void>;
 
@@ -36,0 +36,0 @@ /** Exits this process */

src/lib/process-utils/child-process-proxy.js

 // Forked from probe.gl under MIT license, Copyright (c) 2015 - 2017 Uber Technologies, Inc.
 
 /* eslint-disable no-console */
-/* global process, setTimeout, clearTimeout, console */
 import ChildProcess from 'child_process';
@@ -6,0 +5,0 @@ import {assert} from '../env-utils/assert';

src/lib/worker-api/create-worker.d.ts

@@ -6,5 +6,2 @@ type ProcessFunction = (data: any, options: {[key: string]: any}) => Promise<any>;
  */
-export function createWorker(
-  process: ProcessFunction,
-  processInBatches?: Function,
-): void;
+export function createWorker(process: ProcessFunction, processInBatches?: Function): void;

src/lib/worker-api/create-worker.js

 /* eslint-disable no-restricted-globals */
-/* global self */
 /** @typedef {import('../worker-protocol/protocol').WorkerMessageType} WorkerMessageType  */
@@ -4,0 +3,0 @@ /** @typedef {import('../worker-protocol/protocol').WorkerMessagePayload} WorkerMessagePayload */

src/lib/worker-api/process-on-worker.d.ts

@@ -7,6 +7,2 @@ import {WorkerObject} from '../../types';
  */
-export function processOnWorker(
-  worker: WorkerObject,
-  data: any,
-  options?: object
-): Promise<any>;
+export function processOnWorker(worker: WorkerObject, data: any, options?: object): Promise<any>;

src/lib/worker-api/worker-object-utils.d.ts

@@ -10,3 +10,3 @@ import {WorkerObject} from '../../types';
  */
-export function getWorkerObjectURL(worker: WorkerObject, options: object): string
+export function getWorkerObjectURL(worker: WorkerObject, options: object): string;
 
@@ -30,4 +30,4 @@ /**
  * Safely stringify JSON (drop non serializable values like functions and regexps)
- * @param value 
+ * @param value
  */
 export function removeNontransferableOptions(object: object): object;

src/lib/worker-farm/build-worker-url.js

@@ -1,2 +0,1 @@
-/* global URL, Blob */
 import {assert} from '../env-utils/assert';
@@ -3,0 +2,0 @@

src/lib/worker-farm/get-transfer-list.d.ts

@@ -1,2 +0,1 @@
-
 /**
@@ -10,2 +9,6 @@ * Returns an array of Transferrable objects that can be used with postMessage
  */
-export function getTransferList(object: any, recursive?: boolean, transfers?: Set<any>): Transferable[];
+export function getTransferList(
+  object: any,
+  recursive?: boolean,
+  transfers?: Set<any>
+): Transferable[];

src/lib/worker-farm/get-transfer-list.js

 // NOTE - there is a copy of this function is both in core and loader-utils
 // core does not need all the utils in loader-utils, just this one.
 
-/* global MessagePort, ImageBitmap, OffscreenCanvas */
-
 // Returns an array of Transferrable objects that can be used with postMessage
@@ -7,0 +5,0 @@ // https://developer.mozilla.org/en-US/docs/Web/API/Worker/postMessage

src/lib/worker-farm/worker-body.d.ts

@@ -16,4 +16,8 @@ import {WorkerMessageType, WorkerMessagePayload} from '../worker-protocol/protocol';
 
-  static addEventListener(onMessage: (type: WorkerMessageType, payload: WorkerMessagePayload) => any);
-  static removeEventListener(onMessage: (type: WorkerMessageType, payload: WorkerMessagePayload) => any);
+  static addEventListener(
+    onMessage: (type: WorkerMessageType, payload: WorkerMessagePayload) => any
+  );
+  static removeEventListener(
+    onMessage: (type: WorkerMessageType, payload: WorkerMessagePayload) => any
+  );
 }

src/lib/worker-farm/worker-body.js

 /* eslint-disable no-restricted-globals */
-/* global self */
 /** @typedef {import('../worker-protocol/protocol').WorkerMessageData} WorkerMessageData */
@@ -4,0 +3,0 @@ /** @typedef {import('../worker-protocol/protocol').WorkerMessageType} WorkerMessageType  */

src/lib/worker-farm/worker-farm.d.ts

@@ -11,3 +11,3 @@ import {WorkerPool} from '../..';
   onDebug?: () => void;
-}
+};
 
@@ -49,3 +49,3 @@ /**
    */
-  getWorkerPool(options: {name: string, source?: string, url?: string}): WorkerPool;
+  getWorkerPool(options: {name: string; source?: string; url?: string}): WorkerPool;
 }

src/lib/worker-farm/worker-pool.d.ts

@@ -26,3 +26,3 @@ import WorkerJob from './worker-job';
     onDebug?: (options: OnDebugParameters) => any;
-    reuseWorkers?: boolean
+    reuseWorkers?: boolean;
   });
@@ -29,0 +29,0 @@

src/lib/worker-farm/worker-thread.d.ts

@@ -1,2 +0,1 @@
-
 export type WorkerThreadProps = {
@@ -6,3 +5,3 @@ name: string;
   url?: string;
-}
+};
 
@@ -9,0 +8,0 @@ /**

src/lib/worker-farm/worker-thread.js

@@ -1,2 +0,1 @@
-/* global Worker */
 /** @typedef {import('./worker-thread').WorkerThreadProps} WorkerThreadProps */
@@ -3,0 +2,0 @@ import {assert} from '../env-utils/assert';

src/lib/worker-farm/worker-utils.js

@@ -1,2 +0,1 @@
-/* global URL, Blob */
 import {assert} from '../env-utils/assert';
@@ -3,0 +2,0 @@

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Number of package files

155

increased by1.31%

Worsened metrics

Total package byte prevSize

356664

decreased by-0.52%

Lines of code

5540

decreased by-1.46%

No dependency changes