scramjet - npm Package Compare versions

Comparing version 4.36.9 to 4.37.0

.d.ts/index.d.ts

@@ -10,3 +10,30 @@ import {Readable, Writable, Transform} from "stream";
 
+interface ArrayOptions {
+    concurrency?: number;
+    signal?: AbortSignal;
+}
+
+type SignalOption = Pick<ArrayOptions, "signal">;
+
 declare class PromiseTransform implements Readable, Writable {
+    [Symbol.asyncIterator](): AsyncIterableIterator<any>;
+    [Symbol.asyncDispose](): Promise<void>;
+    iterator(options?: { destroyOnReturn?: boolean; }): AsyncIterableIterator<any>;
+    map(fn: (data: any, options?: SignalOption) => any, options?: ArrayOptions): never;
+    filter(fn: (data: any, options?: SignalOption) => boolean | Promise<boolean>, options?: ArrayOptions): never;
+    forEach(fn: (data: any, options?: SignalOption) => void | Promise<void>, options?: ArrayOptions): never;
+    toArray(options?: SignalOption): never;
+    some(fn: (data: any, options?: SignalOption) => boolean | Promise<boolean>, options?: ArrayOptions): never;
+    find<T>(fn: (data: any, options?: SignalOption) => data is T, options?: ArrayOptions): never;
+    find(fn: (data: any, options?: SignalOption) => boolean | Promise<boolean>, options?: ArrayOptions): never;
+    every(fn: (data: any, options?: SignalOption) => boolean | Promise<boolean>, options?: ArrayOptions): never;
+    flatMap(fn: (data: any, options?: SignalOption) => any, options?: ArrayOptions): never;
+    drop(limit: number, options?: SignalOption): Readable;
+    take(limit: number, options?: SignalOption): Readable;
+    asIndexedPairs(options?: SignalOption): Readable;
+    reduce<T = any>(fn: (previous: any, data: any, options?: SignalOption) => T, initial?: undefined, options?: SignalOption): never;
+    reduce<T = any>(fn: (previous: T, data: any, options?: SignalOption) => T, initial: T, options?: SignalOption): never;
+    [Symbol.asyncIterator](): AsyncIterableIterator<any>;
+    compose<T extends NodeJS.ReadableStream>(stream: T | ((source: any) => void) | Iterable<T> | AsyncIterable<T>, options?: { signal: AbortSignal; }): T;
+    compose<T extends NodeJS.ReadableStream>(stream: T | ((source: any) => void) | Iterable<T> | AsyncIterable<T>, options?: { signal: AbortSignal; }): T;
     writableNeedDrain: boolean;
@@ -193,2 +220,14 @@ closed: boolean;
 declare class DataStream extends PromiseTransform {
+    map(fn: (data: any, options?: SignalOption) => any, options: ArrayOptions): never;
+    filter(fn: (data: any, options: SignalOption) => boolean | Promise<boolean>, options: ArrayOptions): never;
+    forEach(fn: (data: any, options: SignalOption) => void | Promise<void>, options: ArrayOptions): never;
+    toArray(options: SignalOption): never;
+    some(fn: (data: any, options: SignalOption) => boolean | Promise<boolean>, options: ArrayOptions): never;
+    find<T>(fn: (data: any, options: SignalOption) => data is T, options: ArrayOptions): never;
+    find(fn: (data: any, options: SignalOption) => boolean | Promise<boolean>, options: ArrayOptions): never;
+    every(fn: (data: any, options: SignalOption) => boolean | Promise<boolean>, options: ArrayOptions): never;
+    flatMap(fn: (data: any, options: SignalOption) => any, options: ArrayOptions): never;
+    reduce<T = any>(fn: (previous: any, data: any, options: SignalOption) => T, initial: undefined, options: SignalOption): never;
+    reduce<T = any>(fn: (previous: T, data: any, options: SignalOption) => T, initial: T, options: SignalOption): never;
+
     /**
@@ -195,0 +234,0 @@ * DataStream is the primary stream type for Scramjet. When you parse your stream, just pipe it you can then perform calculations on the data objects streamed through your flow. Use as: ```javascript const { DataStream } = require('scramjet'); await (DataStream.from(aStream) // create a DataStream .map(findInFiles)           // read some data asynchronously .map(sendToAPI)             // send the data somewhere .run());                    // wait until end ```

package.json

 {
   "name": "scramjet",
-  "version": "4.36.9",
+  "version": "4.37.0",
   "description": "Lightweight and real-time data functional stream programming framework like event-stream, written in ES6 using async await with multi-threading and typescript support",
@@ -79,8 +79,8 @@ "main": "lib/index.js",
   "devDependencies": {
-    "@otris/jsdoc-tsd": "^2.0.11",
-    "@types/node": "^18.7.8",
-    "check-dts": "^0.6.7",
-    "decache": "^4.6.1",
-    "dmd": "^6.1.0",
-    "eslint": "^8.22.0",
+    "@otris/jsdoc-tsd": "^3.0.0",
+    "@types/node": "^20.6.0",
+    "check-dts": "^0.7.2",
+    "decache": "^4.6.2",
+    "dmd": "^6.2.0",
+    "eslint": "^8.49.0",
     "eslint-config-scramjet": "^3.0.0",
@@ -93,19 +93,19 @@ "fancy-log": "^2.0.0",
     "gulp-shell": "^0.8.0",
-    "jsdoc": "^3.6.11",
-    "jsdoc-api": "^7.1.1",
-    "jsdoc-parse": "^6.1.0",
+    "jsdoc": "^4.0.2",
+    "jsdoc-api": "^8.0.0",
+    "jsdoc-parse": "^6.2.0",
     "node-fetch": "<3",
     "nodeunit-tape-compat": "^1.3.80",
-    "replace-in-file": "^6.3.5",
+    "replace-in-file": "^7.0.1",
     "shelljs": "^0.8.5",
-    "tape": "^5.6.0",
+    "tape": "^5.6.6",
     "through2": "^4.0.2",
-    "typescript": "^4.7.4",
-    "vinyl": "^2.2.1"
+    "typescript": "^5.2.2",
+    "vinyl": "^3.0.0"
   },
   "dependencies": {
-    "papaparse": "^5.3.2",
+    "papaparse": "^5.4.1",
     "rereadable-stream": "^1.4.14",
-    "scramjet-core": "^4.32.10"
+    "scramjet-core": "^4.32.12"
   }
 }

Fixed alerts

Potential vulnerability

Supply chain risk

Initial human review suggests the presence of a vulnerability in this package. It is pending further analysis and confirmation.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

330497

0.96%

Lines of code

2813

1.3%

Number of medium supply chain risk alerts

4

-20%

Dependency changes

• Updated

  papaparse@^5.4.1

• Updated

  scramjet-core@^4.32.12