peek-readable
Advanced tools
Comparing version 4.0.0 to 5.0.0-alpha.0
@@ -0,0 +0,0 @@ export declare const defaultMessages = "End-Of-Stream"; |
@@ -1,13 +0,9 @@ | ||
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.EndOfStreamError = exports.defaultMessages = void 0; | ||
exports.defaultMessages = 'End-Of-Stream'; | ||
export const defaultMessages = 'End-Of-Stream'; | ||
/** | ||
* Thrown on read operation of the end of file or stream has been reached | ||
*/ | ||
class EndOfStreamError extends Error { | ||
export class EndOfStreamError extends Error { | ||
constructor() { | ||
super(exports.defaultMessages); | ||
super(defaultMessages); | ||
} | ||
} | ||
exports.EndOfStreamError = EndOfStreamError; |
@@ -0,0 +0,0 @@ /// <reference types="node" /> |
@@ -1,7 +0,3 @@ | ||
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.StreamReader = exports.EndOfStreamError = void 0; | ||
const EndOfFileStream_1 = require("./EndOfFileStream"); | ||
var EndOfFileStream_2 = require("./EndOfFileStream"); | ||
Object.defineProperty(exports, "EndOfStreamError", { enumerable: true, get: function () { return EndOfFileStream_2.EndOfStreamError; } }); | ||
import { EndOfStreamError } from './EndOfFileStream'; | ||
export { EndOfStreamError } from './EndOfFileStream'; | ||
class Deferred { | ||
@@ -16,3 +12,3 @@ constructor() { | ||
const maxStreamReadSize = 1 * 1024 * 1024; // Maximum request length on read-stream operation | ||
class StreamReader { | ||
export class StreamReader { | ||
constructor(s) { | ||
@@ -29,3 +25,3 @@ this.s = s; | ||
} | ||
this.s.once('end', () => this.reject(new EndOfFileStream_1.EndOfStreamError())); | ||
this.s.once('end', () => this.reject(new EndOfStreamError())); | ||
this.s.once('error', err => this.reject(err)); | ||
@@ -58,3 +54,3 @@ this.s.once('close', () => this.reject(new Error('Stream closed'))); | ||
if (this.peekQueue.length === 0 && this.endOfStream) { | ||
throw new EndOfFileStream_1.EndOfStreamError(); | ||
throw new EndOfStreamError(); | ||
} | ||
@@ -139,2 +135,1 @@ let remaining = length; | ||
} | ||
exports.StreamReader = StreamReader; |
{ | ||
"name": "peek-readable", | ||
"version": "4.0.0", | ||
"version": "5.0.0-alpha.0", | ||
"description": "Read and peek from a readable stream", | ||
@@ -28,3 +28,3 @@ "author": { | ||
"engines": { | ||
"node": ">=8" | ||
"node": ">=12.20" | ||
}, | ||
@@ -37,2 +37,3 @@ "repository": { | ||
"main": "lib/index.js", | ||
"exports": "./lib/index.js", | ||
"types": "lib/index.d.ts", | ||
@@ -39,0 +40,0 @@ "bugs": { |
@@ -0,0 +0,0 @@ ![Node.js CI](https://github.com/Borewit/peek-readable/workflows/Node.js%20CI/badge.svg) |
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
No v1
QualityPackage is not semver >=1. This means it is not stable and does not support ^ ranges.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
13610
190
2