scramjet - npm Package Compare versions

Comparing version 4.33.5 to 4.34.0

.d.ts/index.d.ts

@@ -1,2 +0,2 @@
-import {Readable, Writable, Transform, PassThrough, WritableOptions} from "stream";
+import {Readable, Writable, Transform, WritableOptions} from "stream";
 
@@ -8,10 +8,51 @@ import {EventEmitter} from "events";
 
-function pipelineOverride(...a: never[]): never;
-namespace pipelineOverride {
-    function __promisify__(...a: never[]): never;
+declare class PromiseTransform implements NodeJS.ReadableStream, NodeJS.WritableStream {
+    readable: boolean;
+    read(size?: number | undefined): string | Buffer;
+    setEncoding(encoding: string): this;
+    pause(): this;
+    resume(): this;
+    isPaused(): boolean;
+    pipe<T extends NodeJS.WritableStream>(destination: T, options?: { end?: boolean | undefined; } | undefined): T;
+    unpipe(destination?: NodeJS.WritableStream | undefined): this;
+    unshift(chunk: string | Uint8Array, encoding?: "ascii" | "utf8" | "utf-8" | "utf16le" | "ucs2" | "ucs-2" | "base64" | "latin1" | "binary" | "hex" | undefined): void;
+    wrap(oldStream: NodeJS.ReadableStream): this;
+    [Symbol.asyncIterator](): AsyncIterableIterator<string | Buffer>;
+    addListener(event: string | symbol, listener: (...args: any[]) => void): this;
+    on(event: string | symbol, listener: (...args: any[]) => void): this;
+    once(event: string | symbol, listener: (...args: any[]) => void): this;
+    removeListener(event: string | symbol, listener: (...args: any[]) => void): this;
+    off(event: string | symbol, listener: (...args: any[]) => void): this;
+    removeAllListeners(event?: string | symbol | undefined): this;
+    setMaxListeners(n: number): this;
+    getMaxListeners(): number;
+    listeners(event: string | symbol): Function[];
+    rawListeners(event: string | symbol): Function[];
+    emit(event: string | symbol, ...args: any[]): boolean;
+    listenerCount(type: string | symbol): number;
+    prependListener(event: string | symbol, listener: (...args: any[]) => void): this;
+    prependOnceListener(event: string | symbol, listener: (...args: any[]) => void): this;
+    eventNames(): (string | symbol)[];
+    writable: boolean;
+    write(buffer: string | Uint8Array, cb?: ((err?: Error | null | undefined) => void) | undefined): boolean;
+    write(str: string, encoding?: string | undefined, cb?: ((err?: Error | null | undefined) => void) | undefined): boolean;
+    end(cb?: (() => void) | undefined): void;
+    end(data: string | Uint8Array, cb?: (() => void) | undefined): void;
+    end(str: string, encoding?: string | undefined, cb?: (() => void) | undefined): void;
+    addListener(event: string | symbol, listener: (...args: any[]) => void): this;
+    on(event: string | symbol, listener: (...args: any[]) => void): this;
+    once(event: string | symbol, listener: (...args: any[]) => void): this;
+    removeListener(event: string | symbol, listener: (...args: any[]) => void): this;
+    off(event: string | symbol, listener: (...args: any[]) => void): this;
+    removeAllListeners(event?: string | symbol | undefined): this;
+    setMaxListeners(n: number): this;
+    getMaxListeners(): number;
+    listeners(event: string | symbol): Function[];
+    rawListeners(event: string | symbol): Function[];
+    emit(event: string | symbol, ...args: any[]): boolean;
+    listenerCount(type: string | symbol): number;
+    prependListener(event: string | symbol, listener: (...args: any[]) => void): this;
+    prependOnceListener(event: string | symbol, listener: (...args: any[]) => void): this;
+    eventNames(): (string | symbol)[];
 }
-
-class PromiseTransform extends Transform {
-    static pipeline: typeof pipelineOverride | never;
-}
 /**
@@ -431,11 +472,2 @@ * Creates a DataStream that's piped from the passed readable.
     /**
-     * Override of node.js Readable pipe.
-     * 
-     * Except for calling overridden method it proxies errors to piped stream.
-     * @param to Writable stream to write to
-     * @param options
-     */
-    pipe(to: Writable, options?: WritableOptions): Writable;
-
-    /**
      * Creates a BufferStream.
@@ -442,0 +474,0 @@ *

docs/data-stream.md

@@ -51,3 +51,2 @@ ![Scramjet Logo](https://signicode.com/scramjet-logo-light.svg)
     * [dataStream.raise(err)](#module_scramjet.DataStream+raise)
-    * [dataStream.pipe(to, [options])](#module_scramjet.DataStream+pipe) ↺ <code>Writable</code>
     * [dataStream.bufferify(serializer)](#module_scramjet.DataStream+bufferify) ↺ [<code>BufferStream</code>](buffer-stream.md#module_scramjet.BufferStream)
@@ -485,18 +484,2 @@ * [dataStream.stringify([serializer])](#module_scramjet.DataStream+stringify) ↺ [<code>StringStream</code>](string-stream.md#module_scramjet.StringStream)
 
-<a name="module_scramjet.DataStream+pipe"></a>
-
-### dataStream.pipe(to, [options]) : Writable ↺
-Override of node.js Readable pipe.
-
-Except for calling overridden method it proxies errors to piped stream.
-
-**Kind**: instance method of [<code>DataStream</code>](#module_scramjet.DataStream)  
-**Chainable**  
-**Returns**: <code>Writable</code> - the `to` stream  
-
-| Param | Type | Default | Description |
-| --- | --- | --- | --- |
-| to | <code>Writable</code> |  | Writable stream to write to |
-| [options] | <code>WritableOptions</code> | <code>{}</code> |  |
-
 <a name="module_scramjet.DataStream+bufferify"></a>
@@ -503,0 +486,0 @@

package.json

 {
   "name": "scramjet",
-  "version": "4.33.5",
+  "version": "4.34.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",
@@ -69,3 +69,3 @@ "main": "lib/index.js",
     "@otris/jsdoc-tsd": "^2.0.0",
-    "@types/node": "^14.0.24",
+    "@types/node": "^14.0.26",
     "decache": "^4.6.0",
@@ -80,9 +80,9 @@ "dmd": "^5.0.2",
     "gulp-shell": "^0.8.0",
-    "jsdoc": "^3.6.4",
+    "jsdoc": "^3.6.5",
     "jsdoc-api": "^6.0.0",
     "jsdoc-parse": "^5.0.0",
-    "nodeunit-tape-compat": "^1.3.51",
+    "nodeunit-tape-compat": "^1.3.52",
     "replace-in-file": "^6.1.0",
     "request": "^2.88.2",
-    "request-promise-native": "^1.0.8",
+    "request-promise-native": "^1.0.9",
     "shelljs": "^0.8.4",
@@ -95,5 +95,5 @@ "tape": "^5.0.1",
     "papaparse": "^5.2.0",
-    "rereadable-stream": "^1.3.33",
-    "scramjet-core": "^4.27.8"
+    "rereadable-stream": "^1.3.34",
+    "scramjet-core": "^4.28.0"
   }
 }

README.md

@@ -317,3 +317,2 @@ ![Scramjet Logo](https://signicode.com/scramjet-logo-light.svg)
 * [`dataStream.raise(err) ⇄`](docs/data-stream.md#module_scramjet.DataStream+raise) - Executes all error handlers and if none resolves, then emits an error.
-* [`dataStream.pipe(to, [options]) : Writable ↺`](docs/data-stream.md#module_scramjet.DataStream+pipe) - Override of node.js Readable pipe.
 * [`dataStream.bufferify(serializer) : BufferStream ↺`](docs/data-stream.md#module_scramjet.DataStream+bufferify) - Creates a BufferStream.
@@ -320,0 +319,0 @@ * [`dataStream.stringify([serializer]) : StringStream ↺`](docs/data-stream.md#module_scramjet.DataStream+stringify) - Creates a StringStream.

No alert changes

Improved metrics

Total package byte prevSize

311431

increased by0.6%

Lines of code

2968

increased by1.16%

Worsened metrics

Number of lines in readme file

499

decreased by-0.2%

Dependency changes

• Updatedrereadable-stream@^1.3.34

• Updatedscramjet-core@^4.28.0