@xylabs/threads - npm Package Compare versions

Comparing version 4.0.2 to 4.0.3

dist/esm/master/spawn.js

@@ -67,5 +67,3 @@ "use strict";
         workerTermination.then(() => {
-            const terminationEvent = {
-                type: master_1.WorkerEventType.termination,
-            };
+            const terminationEvent = { type: master_1.WorkerEventType.termination };
             worker.removeEventListener('message', messageHandler);
@@ -72,0 +70,0 @@ worker.removeEventListener('unhandledrejection', rejectionHandler);

dist/esm/worker/index.js

@@ -31,5 +31,3 @@ "use strict";
     const initMessage = {
-        exposed: {
-            type: 'function',
-        },
+        exposed: { type: 'function' },
         type: messages_1.WorkerMessageType.init,
@@ -36,0 +34,0 @@ };

dist/index.d.ts

@@ -5,4 +5,4 @@ export { registerSerializer } from './common';
 export { ExposedToThreadType as ExposedAs } from './master/spawn';
-export { DefaultSerializer, JsonSerializable, Serializer, SerializerImplementation } from './serializers';
+export { DefaultSerializer, JsonSerializable, Serializer, SerializerImplementation, } from './serializers';
 export { Transfer, TransferDescriptor } from './transferable';
 export { expose } from './worker/index';

dist/master/pool.d.ts

@@ -49,3 +49,3 @@ import { Observable } from 'observable-fns';
 };
-export { PoolEvent, PoolEventType, QueuedTask } from './pool-types';
+export { PoolEvent, PoolEventType, QueuedTask, } from './pool-types';
 export { Thread } from './thread';

dist/master/spawn.js

@@ -67,5 +67,3 @@ "use strict";
         workerTermination.then(() => {
-            const terminationEvent = {
-                type: master_1.WorkerEventType.termination,
-            };
+            const terminationEvent = { type: master_1.WorkerEventType.termination };
             worker.removeEventListener('message', messageHandler);
@@ -72,0 +70,0 @@ worker.removeEventListener('unhandledrejection', rejectionHandler);

dist/worker/index.js

@@ -31,5 +31,3 @@ "use strict";
     const initMessage = {
-        exposed: {
-            type: 'function',
-        },
+        exposed: { type: 'function' },
         type: messages_1.WorkerMessageType.init,
@@ -36,0 +34,0 @@ };

observable.js

@@ -0,1 +1,2 @@
+/* eslint-disable @typescript-eslint/no-require-imports */
 module.exports = require('./dist/observable')

package.json

 {
   "name": "@xylabs/threads",
-  "version": "4.0.2",
+  "version": "4.0.3",
   "description": "Web workers & worker threads as simple as a function call",
@@ -87,3 +87,3 @@ "license": "MIT",
   "dependencies": {
-    "@babel/types": "^7.25.2",
+    "@babel/types": "^7.25.4",
     "callsites-3-1-0": "npm:callsites@3.1.0",
@@ -100,4 +100,5 @@ "debug": "^4.3.6",
     "@types/execa": "^2.0.0",
-    "@types/node": "^22.4.0",
+    "@types/node": "^22.5.0",
     "@types/webpack": "^5.28.5",
+    "@xylabs/ts-scripts-yarn3": "^4.0.0",
     "ava": "^6.1.3",
@@ -111,4 +112,4 @@ "chai": "^5.1.1",
     "raw-loader": "^4.0.2",
-    "rimraf": "^6.0.1",
-    "rollup": "^4.20.0",
+    "rimraf": "^5",
+    "rollup": "^4.21.0",
     "threads-plugin": "^1.4.0",
@@ -119,5 +120,5 @@ "tiny-worker": "^2.3.0",
     "typescript": "^5.5.4",
-    "undici-types": "^6.19.6",
+    "undici-types": "^6.19.8",
     "wavy": "^1.0.4",
-    "webpack": "^5.93.0",
+    "webpack": "^5.94.0",
     "worker-plugin": "^5.0.1"
@@ -124,0 +125,0 @@ },

register.js

@@ -0,1 +1,2 @@
+/* eslint-disable @typescript-eslint/no-require-imports */
 require('./dist/master/register')

rollup.config.js

@@ -0,2 +1,4 @@
+/* eslint-disable @typescript-eslint/no-require-imports */
 const commonjs = require('@rollup/plugin-commonjs')
+/* eslint-disable @typescript-eslint/no-require-imports */
 const { nodeResolve } = require('@rollup/plugin-node-resolve')
@@ -3,0 +5,0 @@

src/common.ts

 /* eslint-disable @typescript-eslint/no-explicit-any */
-import type { JsonSerializable, Serializer, SerializerImplementation } from './serializers'
+import type {
+  JsonSerializable, Serializer, SerializerImplementation,
+} from './serializers'
 import { DefaultSerializer, extendSerializer } from './serializers'
@@ -4,0 +6,0 @@

src/index.ts

@@ -6,4 +6,6 @@ /* eslint-disable import-x/no-internal-modules */
 export { ExposedToThreadType as ExposedAs } from './master/spawn'
-export { DefaultSerializer, JsonSerializable, Serializer, SerializerImplementation } from './serializers'
+export {
+  DefaultSerializer, JsonSerializable, Serializer, SerializerImplementation,
+} from './serializers'
 export { Transfer, TransferDescriptor } from './transferable'
 export { expose } from './worker/index'

src/master/implementation.browser.ts

@@ -0,1 +1,2 @@
+/* eslint-disable @stylistic/max-len */
 /* eslint-disable import-x/no-internal-modules */
@@ -2,0 +3,0 @@ // tslint:disable max-classes-per-file

src/master/implementation.node.ts

@@ -21,3 +21,5 @@ /* eslint-disable @typescript-eslint/no-require-imports */
 
-import type { ImplementationExport, ThreadsWorkerOptions, WorkerImplementation } from '../types/master'
+import type {
+  ImplementationExport, ThreadsWorkerOptions, WorkerImplementation,
+} from '../types/master'
 
@@ -24,0 +26,0 @@ interface WorkerGlobalScope {

src/master/invocation-proxy.ts

@@ -16,4 +16,6 @@ /* eslint-disable import-x/no-internal-modules */
 import { isTransferDescriptor } from '../transferable'
-import type { ModuleMethods, ModuleProxy, ProxyableFunction, Worker as WorkerType } from '../types/master'
 import type {
+  ModuleMethods, ModuleProxy, ProxyableFunction, Worker as WorkerType,
+} from '../types/master'
+import type {
   MasterJobCancelMessage,
@@ -23,3 +25,4 @@ MasterJobRunMessage,
   WorkerJobResultMessage,
-  WorkerJobStartMessage } from '../types/messages'
+  WorkerJobStartMessage,
+} from '../types/messages'
 import {
@@ -26,0 +29,0 @@ MasterMessageType,

src/master/pool.ts

@@ -11,7 +11,11 @@ /* eslint-disable import-x/export */
 import DebugLogger from 'debug'
-import { multicast, Observable, Subject } from 'observable-fns'
+import {
+  multicast, Observable, Subject,
+} from 'observable-fns'
 
 import { allSettled } from '../ponyfills'
 import { defaultPoolSize } from './implementation'
-import type { PoolEvent, QueuedTask, TaskRunFunction, WorkerDescriptor } from './pool-types'
+import type {
+  PoolEvent, QueuedTask, TaskRunFunction, WorkerDescriptor,
+} from './pool-types'
 import { PoolEventType } from './pool-types'
@@ -393,3 +397,5 @@ import { Thread } from './thread'
 
-export { PoolEvent, PoolEventType, QueuedTask } from './pool-types'
+export {
+  PoolEvent, PoolEventType, QueuedTask,
+} from './pool-types'
 export { Thread } from './thread'

src/master/spawn.ts

@@ -9,3 +9,5 @@ /* eslint-disable import-x/no-internal-modules */
 import { createPromiseWithResolver } from '../promise'
-import { $errors, $events, $terminate, $worker } from '../symbols'
+import {
+  $errors, $events, $terminate, $worker,
+} from '../symbols'
 import type {
@@ -20,6 +22,5 @@ FunctionThread,
   WorkerMessageEvent,
-  WorkerTerminationEvent } from '../types/master'
-import {
-  WorkerEventType,
+  WorkerTerminationEvent,
 } from '../types/master'
+import { WorkerEventType } from '../types/master'
 import type { WorkerInitMessage, WorkerUncaughtErrorMessage } from '../types/messages'
@@ -99,5 +100,3 @@ import type { WorkerFunction, WorkerModule } from '../types/worker'
     workerTermination.then(() => {
-      const terminationEvent: WorkerTerminationEvent = {
-        type: WorkerEventType.termination,
-      }
+      const terminationEvent: WorkerTerminationEvent = { type: WorkerEventType.termination }
       worker.removeEventListener('message', messageHandler)
@@ -104,0 +103,0 @@ worker.removeEventListener('unhandledrejection', rejectionHandler)

src/master/thread.ts

 /* eslint-disable import-x/no-internal-modules */
 import type { Observable } from 'observable-fns'
 
-import { $errors, $events, $terminate } from '../symbols'
+import {
+  $errors, $events, $terminate,
+} from '../symbols'
 import type { Thread as ThreadType, WorkerEvent } from '../types/master'
@@ -6,0 +8,0 @@

src/types/master.ts

@@ -10,3 +10,5 @@ /* eslint-disable @typescript-eslint/no-explicit-any */
 import type { ObservablePromise } from '../observable-promise'
-import type { $errors, $events, $terminate, $worker } from '../symbols'
+import type {
+  $errors, $events, $terminate, $worker,
+} from '../symbols'
 import type { TransferDescriptor } from '../transferable'
@@ -13,0 +15,0 @@

src/worker/index.ts

@@ -18,3 +18,4 @@ /* eslint-disable import-x/no-internal-modules */
   WorkerJobStartMessage,
-  WorkerUncaughtErrorMessage } from '../types/messages'
+  WorkerUncaughtErrorMessage,
+} from '../types/messages'
 import {
@@ -56,5 +57,3 @@ MasterMessageType,
   const initMessage: WorkerInitMessage = {
-    exposed: {
-      type: 'function',
-    },
+    exposed: { type: 'function' },
     type: WorkerMessageType.init,
@@ -61,0 +60,0 @@ }

test-tooling/rollup/app.js

 /* eslint-disable no-restricted-imports */
-import { spawn, Thread, Worker } from '../..'
+import {
+  spawn, Thread, Worker,
+} from '../..'
 
@@ -4,0 +6,0 @@ async function run() {

test-tooling/tsconfig/minimal.ts

 /* eslint-disable no-restricted-imports */
 /* eslint-disable @typescript-eslint/no-floating-promises */
-import { spawn, Thread, Worker } from '../..'
+import {
+  spawn, Thread, Worker,
+} from '../..'
 
@@ -5,0 +7,0 @@ async function main() {

test-tooling/webpack/app.ts

 /* eslint-disable @typescript-eslint/no-explicit-any */
 
-import { isWorkerRuntime, Pool, spawn, Worker } from '../../src/index'
+import {
+  isWorkerRuntime, Pool, spawn, Worker,
+} from '../../src/index'
 
@@ -5,0 +7,0 @@ type AdditionWorker = (a: number, b: number) => number

test-tooling/webpack/webpack.node.config.js

@@ -0,1 +1,2 @@
+/* eslint-disable @typescript-eslint/no-require-imports */
 const path = require('node:path')
@@ -8,5 +9,3 @@ const ThreadsPlugin = require('threads-plugin')
   entry: require.resolve('./app.ts'),
-  externals: {
-    'tiny-worker': 'tiny-worker',
-  },
+  externals: { 'tiny-worker': 'tiny-worker' },
   mode: 'development',
@@ -17,7 +16,3 @@ module: {
         loader: 'ts-loader',
-        options: {
-          compilerOptions: {
-            module: 'esnext',
-          },
-        },
+        options: { compilerOptions: { module: 'esnext' } },
         test: /\.ts$/,
@@ -34,6 +29,4 @@ },
   plugins: [new ThreadsPlugin()],
-  resolve: {
-    extensions: ['.js', '.ts'],
-  },
+  resolve: { extensions: ['.js', '.ts'] },
   target: 'node',
 }

test-tooling/webpack/webpack.web.config.js

@@ -0,1 +1,2 @@
+/* eslint-disable @typescript-eslint/no-require-imports */
 const path = require('node:path')
@@ -13,7 +14,3 @@ const ThreadsPlugin = require('threads-plugin')
         loader: 'ts-loader',
-        options: {
-          compilerOptions: {
-            module: 'esnext',
-          },
-        },
+        options: { compilerOptions: { module: 'esnext' } },
         test: /\.ts$/,
@@ -30,6 +27,4 @@ },
   plugins: [new ThreadsPlugin()],
-  resolve: {
-    extensions: ['.js', '.ts'],
-  },
+  resolve: { extensions: ['.js', '.ts'] },
   target: 'web',
 }

test/pool.test.ts

@@ -9,3 +9,5 @@ /* eslint-disable import-x/no-internal-modules */
 
-import { Pool, spawn, Worker } from '../src/index'
+import {
+  Pool, spawn, Worker,
+} from '../src/index'
 import type { QueuedTask } from '../src/master/pool'
@@ -69,6 +71,4 @@ import { PoolEventType } from '../src/master/pool'
     },
+    { type: Pool.EventType.taskQueueDrained },
     {
-      type: Pool.EventType.taskQueueDrained,
-    },
-    {
       remainingQueue: [],
@@ -75,0 +75,0 @@ type: Pool.EventType.terminated,

test/serialization.test.ts

 /* eslint-disable import-x/no-internal-modules */
 import test from 'ava'
 
-import { registerSerializer, spawn, Thread, Worker } from '../src/index'
+import {
+  registerSerializer, spawn, Thread, Worker,
+} from '../src/index'
 import { Foo, fooSerializer } from './lib/serialization'
@@ -6,0 +8,0 @@

test/spawn.chromium.mocha.ts

@@ -14,3 +14,5 @@ /* eslint-disable import-x/no-internal-modules */
 
-import { BlobWorker, spawn, Thread } from '..'
+import {
+  BlobWorker, spawn, Thread,
+} from '..'
 
@@ -17,0 +19,0 @@ describe('threads in browser', function () {

test/spawn.test.ts

@@ -7,3 +7,5 @@ /* eslint-disable import-x/no-internal-modules */
 
-import { spawn, Thread, Worker } from '../src/index'
+import {
+  spawn, Thread, Worker,
+} from '../src/index'
 import type { Counter } from './workers/counter'
@@ -10,0 +12,0 @@

test/streaming.test.ts

 import test from 'ava'
 
-import { spawn, Thread, Worker } from '../src/index'
+import {
+  spawn, Thread, Worker,
+} from '../src/index'
 
@@ -5,0 +7,0 @@ test('can use worker returning an observable subject', async (t) => {

test/transferables.test.ts

@@ -7,3 +7,5 @@ /* eslint-disable import-x/no-internal-modules */
 
-import { spawn, Thread, Transfer, Worker } from '../src/index'
+import {
+  spawn, Thread, Transfer, Worker,
+} from '../src/index'
 import type { XorBuffer } from './workers/arraybuffer-xor'
@@ -10,0 +12,0 @@

worker.js

@@ -0,1 +1,2 @@
+// eslint-disable-next-line @typescript-eslint/no-require-imports
 module.exports = require('./dist/worker/index')

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

Total package byte prevSize

274343

increased by0.11%

Lines of code

6672

increased by0.29%

Worsened metrics

Dev dependency count

27

increased by3.85%

Dependency changes

• Updated@babel/types@^7.25.4