@channel/channel
Advanced tools
Comparing version 0.1.0-alpha.0 to 0.1.0
@@ -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" | ||
} | ||
} |
Deprecated
MaintenanceThe maintainer of the package marked it as deprecated. This could indicate that a single version should not be used, or that the package is no longer maintained and any new vulnerabilities will not be fixed.
Found 1 instance in 1 package
No README
QualityPackage does not have a README. This may indicate a failed publish or a low quality package.
Found 1 instance in 1 package
No website
QualityPackage does not have a website.
Found 1 instance in 1 package
27139
1
1
57
1