Compare commits
8 Commits
Author | SHA1 | Date | |
---|---|---|---|
37284da2cc | |||
b0772e2372 | |||
f3eac4a5f7 | |||
fde31ec25d | |||
810b299caa | |||
c71ac16090 | |||
91b52982c0 | |||
97f8327fe9 |
@ -1,7 +1,7 @@
|
|||||||
{
|
{
|
||||||
"name": "@pushrocks/smartpromise",
|
"name": "@pushrocks/smartpromise",
|
||||||
"private": false,
|
"private": false,
|
||||||
"version": "3.1.8",
|
"version": "4.0.2",
|
||||||
"description": "simple promises and Deferred constructs",
|
"description": "simple promises and Deferred constructs",
|
||||||
"main": "dist_ts/index.js",
|
"main": "dist_ts/index.js",
|
||||||
"typings": "dist_ts/index.d.ts",
|
"typings": "dist_ts/index.d.ts",
|
||||||
|
@ -3,6 +3,6 @@
|
|||||||
*/
|
*/
|
||||||
export const commitinfo = {
|
export const commitinfo = {
|
||||||
name: '@pushrocks/smartpromise',
|
name: '@pushrocks/smartpromise',
|
||||||
version: '3.1.8',
|
version: '4.0.2',
|
||||||
description: 'simple promises and Deferred constructs'
|
description: 'simple promises and Deferred constructs'
|
||||||
}
|
}
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
import { defer } from './smartpromise.classes.deferred.js';
|
import { defer } from './smartpromise.classes.deferred.js';
|
||||||
|
|
||||||
export * from './smartpromise.classes.commulativepromise.js';
|
export * from './smartpromise.classes.cumulativedeferred.js';
|
||||||
export * from './smartpromise.classes.deferred.js';
|
export * from './smartpromise.classes.deferred.js';
|
||||||
|
|
||||||
|
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
import { defer } from "./smartpromise.classes.deferred.js";
|
import { defer } from "./smartpromise.classes.deferred.js";
|
||||||
|
|
||||||
export class ComulativeDeferred {
|
export class CumulativeDeferred {
|
||||||
private accumulatedPromises: Promise<any>[] = [];
|
private accumulatedPromises: Promise<any>[] = [];
|
||||||
private deferred = defer();
|
private deferred = defer();
|
||||||
public promise = this.deferred.promise;
|
public promise = this.deferred.promise;
|
||||||
@ -21,6 +21,6 @@ export class ComulativeDeferred {
|
|||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
export const commulativeDefer = () => {
|
export const cumulativeDefer = () => {
|
||||||
return new ComulativeDeferred();
|
return new CumulativeDeferred();
|
||||||
}
|
}
|
@ -13,6 +13,13 @@ export class Deferred<T> {
|
|||||||
public resolve: IResolve<T>;
|
public resolve: IResolve<T>;
|
||||||
public reject: IReject;
|
public reject: IReject;
|
||||||
public status: TDeferredStatus;
|
public status: TDeferredStatus;
|
||||||
|
public claimed = false;
|
||||||
|
public claim() {
|
||||||
|
if (this.claimed) {
|
||||||
|
throw new Error('Deferred already claimed');
|
||||||
|
}
|
||||||
|
this.claimed = true;
|
||||||
|
}
|
||||||
|
|
||||||
public startedAt: number;
|
public startedAt: number;
|
||||||
public stoppedAt: number;
|
public stoppedAt: number;
|
||||||
|
Reference in New Issue
Block a user