@xylabs/threads - npm Package Compare versions

Comparing version 4.0.1 to 4.0.2

dist/common.d.ts

@@ -1,4 +0,4 @@
-import { JsonSerializable, SerializerImplementation } from './serializers';
+import type { JsonSerializable, SerializerImplementation } from './serializers';
 export declare function registerSerializer(serializer: SerializerImplementation<JsonSerializable>): void;
 export declare function deserialize(message: JsonSerializable): any;
 export declare function serialize(input: any): JsonSerializable;

dist/esm/types/master.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.WorkerEventType = void 0;
-const symbols_1 = require("../symbols");
 var WorkerEventType;
@@ -6,0 +5,0 @@ (function (WorkerEventType) {

dist/master/implementation.browser.d.ts

@@ -1,4 +0,4 @@
-import { ImplementationExport } from '../types/master';
+import type { ImplementationExport } from '../types/master';
 export declare const defaultPoolSize: number;
 export declare function getWorkerImplementation(): ImplementationExport;
 export declare function isWorkerRuntime(): boolean;

dist/master/implementation.node.d.ts

@@ -1,4 +0,4 @@
-import { ImplementationExport } from '../types/master';
+import type { ImplementationExport } from '../types/master';
 export declare const defaultPoolSize: number;
 export declare function getWorkerImplementation(): ImplementationExport;
 export declare function isWorkerRuntime(): boolean;

dist/master/index.d.ts

@@ -1,3 +0,2 @@
-import type { BlobWorker as BlobWorkerClass } from '../types/master';
-import { Worker as WorkerType } from '../types/master';
+import type { BlobWorker as BlobWorkerClass, Worker as WorkerType } from '../types/master';
 export { FunctionThread, ModuleThread } from '../types/master';
@@ -4,0 +3,0 @@ export { Pool } from './pool';

dist/master/invocation-proxy.d.ts

@@ -1,3 +0,3 @@
-import { ModuleMethods, ModuleProxy, ProxyableFunction, Worker as WorkerType } from '../types/master';
+import type { ModuleMethods, ModuleProxy, ProxyableFunction, Worker as WorkerType } from '../types/master';
 export declare function createProxyFunction<Args extends any[], ReturnType>(worker: WorkerType, method?: string): ProxyableFunction<Args, ReturnType>;
 export declare function createProxyModule<Methods extends ModuleMethods>(worker: WorkerType, methodNames: string[]): ModuleProxy<Methods>;

dist/master/pool-types.d.ts

@@ -1,2 +0,2 @@
-import { Thread } from './thread';
+import type { Thread } from './thread';
 export declare enum PoolEventType {
@@ -3,0 +3,0 @@ initialized = "initialized",

dist/master/pool.d.ts

 import { Observable } from 'observable-fns';
-import { PoolEvent, PoolEventType, QueuedTask, TaskRunFunction } from './pool-types';
+import type { PoolEvent, QueuedTask, TaskRunFunction } from './pool-types';
+import { PoolEventType } from './pool-types';
 import { Thread } from './thread';
@@ -4,0 +5,0 @@ export declare namespace Pool {

dist/master/spawn.d.ts

@@ -1,3 +0,3 @@
-import { FunctionThread, ModuleThread, StripAsync, Worker as WorkerType } from '../types/master';
-import { WorkerFunction, WorkerModule } from '../types/worker';
+import type { FunctionThread, ModuleThread, StripAsync, Worker as WorkerType } from '../types/master';
+import type { WorkerFunction, WorkerModule } from '../types/worker';
 type ArbitraryWorkerInterface = WorkerFunction & WorkerModule<string> & {
@@ -4,0 +4,0 @@ somekeythatisneverusedinproductioncode123: 'magicmarker123';

dist/master/thread.d.ts

@@ -1,3 +0,3 @@
-import { Observable } from 'observable-fns';
-import { Thread as ThreadType, WorkerEvent } from '../types/master';
+import type { Observable } from 'observable-fns';
+import type { Thread as ThreadType, WorkerEvent } from '../types/master';
 export type Thread = ThreadType;
@@ -4,0 +4,0 @@ export declare const Thread: {

dist/observable-promise.d.ts

@@ -1,2 +0,3 @@
-import { Observable, ObservableLike, SubscriptionObserver } from 'observable-fns';
+import type { ObservableLike, SubscriptionObserver } from 'observable-fns';
+import { Observable } from 'observable-fns';
 type Initializer<T> = (observer: SubscriptionObserver<T>) => UnsubscribeFn | void;
@@ -3,0 +4,0 @@ type Thenable<T> = {

dist/observable.d.ts

@@ -1,2 +0,3 @@
-import { Observable, ObservableLike } from 'observable-fns';
+import type { ObservableLike } from 'observable-fns';
+import { Observable } from 'observable-fns';
 declare const $observers: unique symbol;
@@ -3,0 +4,0 @@ export declare class Subject<T> extends Observable<T> implements ObservableLike<T> {

dist/types/master.d.ts

@@ -1,5 +0,5 @@
-import { Observable } from 'observable-fns';
-import { ObservablePromise } from '../observable-promise';
-import { $errors, $events, $terminate, $worker } from '../symbols';
-import { TransferDescriptor } from '../transferable';
+import type { Observable } from 'observable-fns';
+import type { ObservablePromise } from '../observable-promise';
+import type { $errors, $events, $terminate, $worker } from '../symbols';
+import type { TransferDescriptor } from '../transferable';
 interface ObservableLikeSubscription {
@@ -6,0 +6,0 @@ unsubscribe(): any;

dist/types/master.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.WorkerEventType = void 0;
-const symbols_1 = require("../symbols");
 var WorkerEventType;
@@ -6,0 +5,0 @@ (function (WorkerEventType) {

dist/worker/implementation.d.ts

@@ -1,3 +0,3 @@
-import { AbstractedWorkerAPI } from '../types/worker';
+import type { AbstractedWorkerAPI } from '../types/worker';
 declare const _default: AbstractedWorkerAPI;
 export default _default;

dist/worker/index.d.ts

@@ -1,2 +0,2 @@
-import { WorkerFunction, WorkerModule } from '../types/worker';
+import type { WorkerFunction, WorkerModule } from '../types/worker';
 export { registerSerializer } from '../common';
@@ -3,0 +3,0 @@ export { Transfer } from '../transferable';

package.json

 {
   "name": "@xylabs/threads",
-  "version": "4.0.1",
+  "version": "4.0.2",
   "description": "Web workers & worker threads as simple as a function call",
@@ -72,3 +72,3 @@ "license": "MIT",
   "bugs": {
-    "url": "https://github.com/andywer/threads.js/issues"
+    "url": "git+https://github.com/andywer/threads.js/issues"
   },
@@ -100,3 +100,3 @@ "funding": "https://github.com/andywer/threads.js?sponsor=1",
     "@types/execa": "^2.0.0",
-    "@types/node": "^22.2.0",
+    "@types/node": "^22.4.0",
     "@types/webpack": "^5.28.5",
@@ -106,3 +106,3 @@ "ava": "^6.1.3",
     "cross-env": "^7.0.3",
-    "execa": "^9.3.0",
+    "execa": "^9.3.1",
     "mocha": "^10.7.3",
@@ -112,3 +112,3 @@ "puppet-run": "^0.11.4",
     "raw-loader": "^4.0.2",
-    "rimraf": "^5.0.10",
+    "rimraf": "^6.0.1",
     "rollup": "^4.20.0",
@@ -115,0 +115,0 @@ "threads-plugin": "^1.4.0",

src/common.ts

 /* eslint-disable @typescript-eslint/no-explicit-any */
-import { DefaultSerializer, extendSerializer, JsonSerializable, Serializer, SerializerImplementation } from './serializers'
+import type { JsonSerializable, Serializer, SerializerImplementation } from './serializers'
+import { DefaultSerializer, extendSerializer } from './serializers'
 
@@ -4,0 +5,0 @@ let registeredSerializer: Serializer<JsonSerializable> = DefaultSerializer

src/master/implementation.browser.ts

 /* eslint-disable import-x/no-internal-modules */
 // tslint:disable max-classes-per-file
 
-import { ImplementationExport, ThreadsWorkerOptions } from '../types/master'
+import type { ImplementationExport, ThreadsWorkerOptions } from '../types/master'
 import { getBundleURL } from './get-bundle-url.browser'
@@ -6,0 +6,0 @@

src/master/implementation.node.ts

@@ -18,5 +18,6 @@ /* eslint-disable @typescript-eslint/no-require-imports */
 
-import getCallsites, { CallSite } from 'callsites-3-1-0'
+import type { CallSite } from 'callsites-3-1-0'
+import getCallsites from 'callsites-3-1-0'
 
-import { ImplementationExport, ThreadsWorkerOptions, WorkerImplementation } from '../types/master'
+import type { ImplementationExport, ThreadsWorkerOptions, WorkerImplementation } from '../types/master'
 
@@ -23,0 +24,0 @@ interface WorkerGlobalScope {

src/master/index.ts

 /* eslint-disable import-x/no-internal-modules */
-// tslint:disable no-duplicate-imports
-import type { BlobWorker as BlobWorkerClass } from '../types/master'
-import { Worker as WorkerType } from '../types/master'
+import type { BlobWorker as BlobWorkerClass, Worker as WorkerType } from '../types/master'
 import { getWorkerImplementation } from './implementation'
@@ -6,0 +4,0 @@

src/master/invocation-proxy.ts

@@ -16,10 +16,11 @@ /* eslint-disable import-x/no-internal-modules */
 import { isTransferDescriptor } from '../transferable'
-import { ModuleMethods, ModuleProxy, ProxyableFunction, Worker as WorkerType } from '../types/master'
-import {
+import type { ModuleMethods, ModuleProxy, ProxyableFunction, Worker as WorkerType } from '../types/master'
+import type {
   MasterJobCancelMessage,
   MasterJobRunMessage,
-  MasterMessageType,
   WorkerJobErrorMessage,
   WorkerJobResultMessage,
-  WorkerJobStartMessage,
+  WorkerJobStartMessage } from '../types/messages'
+import {
+  MasterMessageType,
   WorkerMessageType,
@@ -26,0 +27,0 @@ } from '../types/messages'

src/master/pool-types.ts

 /* eslint-disable @typescript-eslint/no-explicit-any */
 /* eslint-disable @typescript-eslint/member-ordering */
-import { Thread } from './thread'
+import type { Thread } from './thread'
 
@@ -5,0 +5,0 @@ /** Pool event type. Specifies the type of each `PoolEvent`. */

src/master/pool.ts

@@ -15,3 +15,4 @@ /* eslint-disable import-x/export */
 import { defaultPoolSize } from './implementation'
-import { PoolEvent, PoolEventType, QueuedTask, TaskRunFunction, WorkerDescriptor } from './pool-types'
+import type { PoolEvent, QueuedTask, TaskRunFunction, WorkerDescriptor } from './pool-types'
+import { PoolEventType } from './pool-types'
 import { Thread } from './thread'
@@ -18,0 +19,0 @@

src/master/spawn.ts

@@ -10,3 +10,3 @@ /* eslint-disable import-x/no-internal-modules */
 import { $errors, $events, $terminate, $worker } from '../symbols'
-import {
+import type {
   FunctionThread,
@@ -18,9 +18,10 @@ ModuleThread,
   WorkerEvent,
-  WorkerEventType,
   WorkerInternalErrorEvent,
   WorkerMessageEvent,
-  WorkerTerminationEvent,
+  WorkerTerminationEvent } from '../types/master'
+import {
+  WorkerEventType,
 } from '../types/master'
-import { WorkerInitMessage, WorkerUncaughtErrorMessage } from '../types/messages'
-import { WorkerFunction, WorkerModule } from '../types/worker'
+import type { WorkerInitMessage, WorkerUncaughtErrorMessage } from '../types/messages'
+import type { WorkerFunction, WorkerModule } from '../types/worker'
 import { createProxyFunction, createProxyModule } from './invocation-proxy'
@@ -27,0 +28,0 @@

src/master/thread.ts

 /* eslint-disable import-x/no-internal-modules */
-import { Observable } from 'observable-fns'
+import type { Observable } from 'observable-fns'
 
 import { $errors, $events, $terminate } from '../symbols'
-import { Thread as ThreadType, WorkerEvent } from '../types/master'
+import type { Thread as ThreadType, WorkerEvent } from '../types/master'
 
@@ -7,0 +7,0 @@ function fail(message: string): never {

src/observable-promise.ts

@@ -8,3 +8,4 @@ /* eslint-disable unicorn/no-thenable */
 /* eslint-disable unicorn/no-this-assignment */
-import { Observable, ObservableLike, SubscriptionObserver } from 'observable-fns'
+import type { ObservableLike, SubscriptionObserver } from 'observable-fns'
+import { Observable } from 'observable-fns'
 
@@ -11,0 +12,0 @@ type OnFulfilled<T, Result = void> = (value: T) => Result

src/observable.ts

 /* eslint-disable @typescript-eslint/no-explicit-any */
-import { Observable, ObservableLike, SubscriptionObserver } from 'observable-fns'
+import type { ObservableLike, SubscriptionObserver } from 'observable-fns'
+import { Observable } from 'observable-fns'
 
@@ -4,0 +5,0 @@ const $observers = Symbol('observers')

src/serializers.ts

 /* eslint-disable import-x/no-internal-modules */
 /* eslint-disable @typescript-eslint/no-explicit-any */
-import { SerializedError } from './types/messages'
+import type { SerializedError } from './types/messages'
 
@@ -5,0 +5,0 @@ export interface Serializer<Msg = JsonSerializable, Input = any> {

src/types/master.ts

@@ -7,7 +7,7 @@ /* eslint-disable @typescript-eslint/no-explicit-any */
 // See <https://github.com/microsoft/TypeScript/issues/28009>
-import { Observable } from 'observable-fns'
+import type { Observable } from 'observable-fns'
 
-import { ObservablePromise } from '../observable-promise'
-import { $errors, $events, $terminate, $worker } from '../symbols'
-import { TransferDescriptor } from '../transferable'
+import type { ObservablePromise } from '../observable-promise'
+import type { $errors, $events, $terminate, $worker } from '../symbols'
+import type { TransferDescriptor } from '../transferable'
 
@@ -14,0 +14,0 @@ interface ObservableLikeSubscription {

src/worker/implementation.browser.ts

@@ -6,3 +6,3 @@ /* eslint-disable import-x/no-internal-modules */
 
-import { AbstractedWorkerAPI } from '../types/worker'
+import type { AbstractedWorkerAPI } from '../types/worker'
 
@@ -9,0 +9,0 @@ interface WorkerGlobalScope {

src/worker/implementation.tiny-worker.ts

@@ -6,3 +6,3 @@ /* eslint-disable import-x/no-internal-modules */
 
-import { AbstractedWorkerAPI } from '../types/worker'
+import type { AbstractedWorkerAPI } from '../types/worker'
 
@@ -9,0 +9,0 @@ interface WorkerGlobalScope {

src/worker/implementation.ts

@@ -7,3 +7,3 @@ /* eslint-disable import-x/no-internal-modules */
 
-import { AbstractedWorkerAPI } from '../types/worker'
+import type { AbstractedWorkerAPI } from '../types/worker'
 import WebWorkerImplementation from './implementation.browser'
@@ -10,0 +10,0 @@ import TinyWorkerImplementation from './implementation.tiny-worker'

src/worker/implementation.worker_threads.ts

 /* eslint-disable import-x/no-internal-modules */
 /* eslint-disable @typescript-eslint/no-explicit-any */
 // tslint:disable no-shadowed-variable
-import { MessagePort } from 'node:worker_threads'
+import type { MessagePort } from 'node:worker_threads'
 
-import { AbstractedWorkerAPI } from '../types/worker'
+import type { AbstractedWorkerAPI } from '../types/worker'
 import WorkerThreads from '../worker_threads'
@@ -8,0 +8,0 @@

src/worker/index.ts

@@ -5,10 +5,10 @@ /* eslint-disable import-x/no-internal-modules */
 import isSomeObservable from 'is-observable-2-1-0'
-import { Observable, Subscription } from 'observable-fns'
+import type { Observable, Subscription } from 'observable-fns'
 
 import { deserialize, serialize } from '../common'
-import { isTransferDescriptor, TransferDescriptor } from '../transferable'
-import {
+import type { TransferDescriptor } from '../transferable'
+import { isTransferDescriptor } from '../transferable'
+import type {
   MasterJobCancelMessage,
   MasterJobRunMessage,
-  MasterMessageType,
   SerializedError,
@@ -19,6 +19,8 @@ WorkerInitMessage,
   WorkerJobStartMessage,
+  WorkerUncaughtErrorMessage } from '../types/messages'
+import {
+  MasterMessageType,
   WorkerMessageType,
-  WorkerUncaughtErrorMessage,
 } from '../types/messages'
-import { WorkerFunction, WorkerModule } from '../types/worker'
+import type { WorkerFunction, WorkerModule } from '../types/worker'
 import Implementation from './implementation'
@@ -25,0 +27,0 @@

test/lib/serialization.ts

 /* eslint-disable @typescript-eslint/no-explicit-any */
 
-import { JsonSerializable, SerializerImplementation } from '../../src/index'
+import type { JsonSerializable, SerializerImplementation } from '../../src/index'
 
@@ -5,0 +5,0 @@ export class Foo<T> {

test/pool.test.ts

@@ -10,3 +10,4 @@ /* eslint-disable import-x/no-internal-modules */
 import { Pool, spawn, Worker } from '../src/index'
-import { PoolEventType, QueuedTask } from '../src/master/pool'
+import type { QueuedTask } from '../src/master/pool'
+import { PoolEventType } from '../src/master/pool'
 
@@ -13,0 +14,0 @@ const workerPath = './workers/hello-world'

test/spawn.test.ts

@@ -5,6 +5,6 @@ /* eslint-disable import-x/no-internal-modules */
 import test from 'ava'
-import { Observable } from 'observable-fns'
+import type { Observable } from 'observable-fns'
 
 import { spawn, Thread, Worker } from '../src/index'
-import { Counter } from './workers/counter'
+import type { Counter } from './workers/counter'
 
@@ -11,0 +11,0 @@ test('can spawn and terminate a thread', async (t) => {

test/transferables.test.ts

@@ -8,3 +8,3 @@ /* eslint-disable import-x/no-internal-modules */
 import { spawn, Thread, Transfer, Worker } from '../src/index'
-import { XorBuffer } from './workers/arraybuffer-xor'
+import type { XorBuffer } from './workers/arraybuffer-xor'
 
@@ -11,0 +11,0 @@ type SpyInit<Args extends any[], OriginalReturn, NewReturn> = (originalFn: (...args: Args) => OriginalReturn) => (...args: Args) => NewReturn

types/is-observable.d.ts

 /* eslint-disable @typescript-eslint/no-explicit-any */
 declare module 'is-observable-2-1-0' {
-  import { Observable } from 'observable-fns'
+  import type { Observable } from 'observable-fns'
 
@@ -5,0 +5,0 @@ function isObservable(thing: any): thing is Observable<any>

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

274028

increased by0.18%

Lines of code

6653

increased by0.12%

No dependency changes