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"
   }
 }

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

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

increased by0.96%

Lines of code

2813

increased by1.3%

Number of medium supply chain risk alerts

4

decreased by-20%

Worsened metrics

Number of downloads

13362

decreased by-22.01%

Dependency changes

• Updatedpapaparse@^5.4.1

• Updatedscramjet-core@^4.32.12