Socket
Socket
Sign inDemoInstall

peek-readable

Package Overview
Dependencies
Maintainers
1
Versions
22
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

peek-readable - npm Package Compare versions

Comparing version 4.0.0 to 5.0.0-alpha.0

0

lib/EndOfFileStream.d.ts

@@ -0,0 +0,0 @@ export declare const defaultMessages = "End-Of-Stream";

10

lib/EndOfFileStream.js

@@ -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

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc