New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More
Socket
Sign inDemoInstall
Socket

@channel/channel

Package Overview
Dependencies
Maintainers
1
Versions
5
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@channel/channel - npm Package Compare versions

Comparing version 0.1.0-alpha.0 to 0.1.0

README.md

12

lib/index.cjs.js

@@ -184,3 +184,3 @@ 'use strict';

if (this.closed) {
return Promise.resolve();
return Promise.resolve(false);
}

@@ -191,7 +191,7 @@ else if (this.pullQueue.length) {

pull.resolve(result);
return Promise.resolve();
return Promise.resolve(true);
}
else if (!this.buffer.full) {
this.buffer.add(value);
return Promise.resolve();
return Promise.resolve(true);
}

@@ -213,3 +213,3 @@ else if (this.pushQueue.length >= this.MAX_QUEUE_LENGTH) {

var push = _d.value;
push.resolve();
push.resolve(false);
}

@@ -265,3 +265,3 @@ }

this.buffer.add(push.value);
push.resolve();
push.resolve(true);
}

@@ -273,3 +273,3 @@ return Promise.resolve(result);

var result = { value: push.value, done: false };
push.resolve();
push.resolve(true);
return Promise.resolve(result);

@@ -276,0 +276,0 @@ }

@@ -34,3 +34,3 @@ export interface ChannelBuffer<T> {

}
export declare type ChannelExecutor<T> = (push: (value: T) => Promise<void>, close: (reason?: any) => void, stop: Promise<void>) => T | void | Promise<T | void>;
export declare type ChannelExecutor<T> = (push: (value: T) => Promise<boolean>, close: (reason?: any) => void, stop: Promise<void>) => T | void | Promise<T | void>;
export declare class ChannelOverflowError extends Error {

@@ -37,0 +37,0 @@ constructor(message: string);

@@ -180,3 +180,3 @@ /*! *****************************************************************************

if (this.closed) {
return Promise.resolve();
return Promise.resolve(false);
}

@@ -187,7 +187,7 @@ else if (this.pullQueue.length) {

pull.resolve(result);
return Promise.resolve();
return Promise.resolve(true);
}
else if (!this.buffer.full) {
this.buffer.add(value);
return Promise.resolve();
return Promise.resolve(true);
}

@@ -209,3 +209,3 @@ else if (this.pushQueue.length >= this.MAX_QUEUE_LENGTH) {

var push = _d.value;
push.resolve();
push.resolve(false);
}

@@ -261,3 +261,3 @@ }

this.buffer.add(push.value);
push.resolve();
push.resolve(true);
}

@@ -269,3 +269,3 @@ return Promise.resolve(result);

var result = { value: push.value, done: false };
push.resolve();
push.resolve(true);
return Promise.resolve(result);

@@ -272,0 +272,0 @@ }

{
"name": "@channel/channel",
"version": "0.1.0-alpha.0",
"version": "0.1.0",
"description": "The missing constructor function for creating safe async iterators",
"license": "MIT",
"homepage": "https://github.com/channeljs/channel",
"files": [

@@ -20,4 +21,3 @@ "/lib"

"access": "public"
},
"gitHead": "c8d1241251183ed8e36c763b24808247c7a1c2e0"
}
}
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