@pushrocks/smartpromise
Advanced tools
Comparing version 3.0.2 to 3.0.5
export interface IResolve<T> { | ||
(value?: T | Promise<T>): void; | ||
(value?: T | PromiseLike<T>): void; | ||
} | ||
@@ -13,2 +13,5 @@ export interface IReject { | ||
status: TDeferredStatus; | ||
startedAt: number; | ||
stoppedAt: number; | ||
readonly duration: number; | ||
constructor(); | ||
@@ -15,0 +18,0 @@ } |
"use strict"; | ||
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) { | ||
return new (P || (P = Promise))(function (resolve, reject) { | ||
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } } | ||
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } } | ||
function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); } | ||
step((generator = generator.apply(thisArg, _arguments || [])).next()); | ||
}); | ||
}; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
@@ -14,7 +6,24 @@ class Deferred { | ||
this.promise = new Promise((resolve, reject) => { | ||
this.resolve = resolve; | ||
this.reject = reject; | ||
this.resolve = (valueArg) => { | ||
this.status = 'fulfilled'; | ||
this.stoppedAt = Date.now(); | ||
resolve(valueArg); | ||
}; | ||
this.reject = (reason) => { | ||
this.status = 'rejected'; | ||
this.stoppedAt = Date.now(); | ||
reject(reason); | ||
}; | ||
this.startedAt = Date.now(); | ||
this.status = 'pending'; | ||
}); | ||
} | ||
get duration() { | ||
if (this.stoppedAt) { | ||
return this.stoppedAt - this.startedAt; | ||
} | ||
else { | ||
return Date.now() - this.startedAt; | ||
} | ||
} | ||
} | ||
@@ -37,3 +46,3 @@ exports.Deferred = Deferred; | ||
}; | ||
exports.map = (inputArg, functionArg) => __awaiter(this, void 0, void 0, function* () { | ||
exports.map = async (inputArg, functionArg) => { | ||
let promiseArray = []; | ||
@@ -48,5 +57,5 @@ let resultArray = []; | ||
} | ||
yield Promise.all(promiseArray); | ||
await Promise.all(promiseArray); | ||
return resultArray; | ||
}); | ||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9pbmRleC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOzs7Ozs7Ozs7O0FBVUE7SUFLRTtRQUNFLElBQUksQ0FBQyxPQUFPLEdBQUcsSUFBSSxPQUFPLENBQUksQ0FBQyxPQUFPLEVBQUUsTUFBTSxFQUFFLEVBQUU7WUFDaEQsSUFBSSxDQUFDLE9BQU8sR0FBRyxPQUFPLENBQUM7WUFDdkIsSUFBSSxDQUFDLE1BQU0sR0FBRyxNQUFNLENBQUM7WUFDckIsSUFBSSxDQUFDLE1BQU0sR0FBRyxTQUFTLENBQUM7UUFDMUIsQ0FBQyxDQUFDLENBQUM7SUFDTCxDQUFDO0NBQ0Y7QUFaRCw0QkFZQztBQUVVLFFBQUEsS0FBSyxHQUFHLEdBQU0sRUFBRTtJQUN6QixPQUFPLElBQUksUUFBUSxFQUFLLENBQUM7QUFDM0IsQ0FBQyxDQUFDO0FBRUY7O0dBRUc7QUFDUSxRQUFBLGVBQWUsR0FBRyxDQUFJLEtBQVMsRUFBYyxFQUFFO0lBQ3hELE9BQU8sT0FBTyxDQUFDLE9BQU8sQ0FBQyxLQUFLLENBQUMsQ0FBQztBQUNoQyxDQUFDLENBQUM7QUFFRjs7R0FFRztBQUNRLFFBQUEsZUFBZSxHQUFHLEdBQUcsQ0FBQyxFQUFFO0lBQ2pDLE9BQU8sT0FBTyxDQUFDLE1BQU0sQ0FBQyxHQUFHLENBQUMsQ0FBQztBQUM3QixDQUFDLENBQUM7QUFNUyxRQUFBLEdBQUcsR0FBRyxDQUFVLFFBQWEsRUFBRSxXQUE4QixFQUFFLEVBQUU7SUFDMUUsSUFBSSxZQUFZLEdBQW1CLEVBQUUsQ0FBQztJQUN0QyxJQUFJLFdBQVcsR0FBRyxFQUFFLENBQUM7SUFDckIsS0FBSyxJQUFJLElBQUksSUFBSSxRQUFRLEVBQUU7UUFDekIsSUFBSSxPQUFPLEdBQWlCLFdBQVcsQ0FBQyxJQUFJLENBQUMsQ0FBQztRQUM5QyxZQUFZLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQyxDQUFDO1FBQzNCLE9BQU8sQ0FBQyxJQUFJLENBQUMsQ0FBQyxDQUFDLEVBQUU7WUFDZixXQUFXLENBQUMsSUFBSSxDQUFDLENBQUMsQ0FBQyxDQUFDO1FBQ3RCLENBQUMsQ0FBQyxDQUFDO0tBQ0o7SUFDRCxNQUFNLE9BQU8sQ0FBQyxHQUFHLENBQUMsWUFBWSxDQUFDLENBQUM7SUFDaEMsT0FBTyxXQUFXLENBQUM7QUFDckIsQ0FBQyxDQUFBLENBQUMifQ== | ||
}; | ||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9pbmRleC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOztBQVVBLE1BQWEsUUFBUTtJQWdCbkI7UUFDRSxJQUFJLENBQUMsT0FBTyxHQUFHLElBQUksT0FBTyxDQUFJLENBQUMsT0FBTyxFQUFFLE1BQU0sRUFBRSxFQUFFO1lBQ2hELElBQUksQ0FBQyxPQUFPLEdBQUcsQ0FBQyxRQUE0QixFQUFFLEVBQUU7Z0JBQzlDLElBQUksQ0FBQyxNQUFNLEdBQUcsV0FBVyxDQUFDO2dCQUMxQixJQUFJLENBQUMsU0FBUyxHQUFHLElBQUksQ0FBQyxHQUFHLEVBQUUsQ0FBQztnQkFDNUIsT0FBTyxDQUFDLFFBQVEsQ0FBQyxDQUFDO1lBQ3BCLENBQUMsQ0FBQztZQUNGLElBQUksQ0FBQyxNQUFNLEdBQUcsQ0FBQyxNQUFXLEVBQUUsRUFBRTtnQkFDNUIsSUFBSSxDQUFDLE1BQU0sR0FBRyxVQUFVLENBQUM7Z0JBQ3pCLElBQUksQ0FBQyxTQUFTLEdBQUcsSUFBSSxDQUFDLEdBQUcsRUFBRSxDQUFDO2dCQUM1QixNQUFNLENBQUMsTUFBTSxDQUFDLENBQUM7WUFDakIsQ0FBQyxDQUFDO1lBQ0YsSUFBSSxDQUFDLFNBQVMsR0FBRyxJQUFJLENBQUMsR0FBRyxFQUFFLENBQUM7WUFDNUIsSUFBSSxDQUFDLE1BQU0sR0FBRyxTQUFTLENBQUM7UUFDMUIsQ0FBQyxDQUFDLENBQUM7SUFDTCxDQUFDO0lBdkJELElBQVcsUUFBUTtRQUNqQixJQUFJLElBQUksQ0FBQyxTQUFTLEVBQUU7WUFDbEIsT0FBTyxJQUFJLENBQUMsU0FBUyxHQUFHLElBQUksQ0FBQyxTQUFTLENBQUM7U0FDeEM7YUFBTTtZQUNMLE9BQU8sSUFBSSxDQUFDLEdBQUcsRUFBRSxHQUFHLElBQUksQ0FBQyxTQUFTLENBQUM7U0FDcEM7SUFDSCxDQUFDO0NBa0JGO0FBaENELDRCQWdDQztBQUVVLFFBQUEsS0FBSyxHQUFHLEdBQU0sRUFBRTtJQUN6QixPQUFPLElBQUksUUFBUSxFQUFLLENBQUM7QUFDM0IsQ0FBQyxDQUFDO0FBRUY7O0dBRUc7QUFDUSxRQUFBLGVBQWUsR0FBRyxDQUFJLEtBQVMsRUFBYyxFQUFFO0lBQ3hELE9BQU8sT0FBTyxDQUFDLE9BQU8sQ0FBQyxLQUFLLENBQUMsQ0FBQztBQUNoQyxDQUFDLENBQUM7QUFFRjs7R0FFRztBQUNRLFFBQUEsZUFBZSxHQUFHLEdBQUcsQ0FBQyxFQUFFO0lBQ2pDLE9BQU8sT0FBTyxDQUFDLE1BQU0sQ0FBQyxHQUFHLENBQUMsQ0FBQztBQUM3QixDQUFDLENBQUM7QUFNUyxRQUFBLEdBQUcsR0FBRyxLQUFLLEVBQUssUUFBYSxFQUFFLFdBQThCLEVBQUUsRUFBRTtJQUMxRSxJQUFJLFlBQVksR0FBbUIsRUFBRSxDQUFDO0lBQ3RDLElBQUksV0FBVyxHQUFHLEVBQUUsQ0FBQztJQUNyQixLQUFLLElBQUksSUFBSSxJQUFJLFFBQVEsRUFBRTtRQUN6QixJQUFJLE9BQU8sR0FBaUIsV0FBVyxDQUFDLElBQUksQ0FBQyxDQUFDO1FBQzlDLFlBQVksQ0FBQyxJQUFJLENBQUMsT0FBTyxDQUFDLENBQUM7UUFDM0IsT0FBTyxDQUFDLElBQUksQ0FBQyxDQUFDLENBQUMsRUFBRTtZQUNmLFdBQVcsQ0FBQyxJQUFJLENBQUMsQ0FBQyxDQUFDLENBQUM7UUFDdEIsQ0FBQyxDQUFDLENBQUM7S0FDSjtJQUNELE1BQU0sT0FBTyxDQUFDLEdBQUcsQ0FBQyxZQUFZLENBQUMsQ0FBQztJQUNoQyxPQUFPLFdBQVcsQ0FBQztBQUNyQixDQUFDLENBQUMifQ== |
{ | ||
"npmci": { | ||
"npmGlobalTools": [ | ||
"npmts" | ||
], | ||
"npmGlobalTools": [], | ||
"npmAccessLevel": "public" | ||
@@ -7,0 +5,0 @@ }, |
{ | ||
"name": "@pushrocks/smartpromise", | ||
"private": false, | ||
"version": "3.0.2", | ||
"version": "3.0.5", | ||
"description": "simple promises and Deferred constructs", | ||
@@ -9,4 +9,4 @@ "main": "dist/index.js", | ||
"scripts": { | ||
"test": "(tsrun test/test.ts)", | ||
"build": "(npmts)" | ||
"test": "(tstest test/)", | ||
"build": "(tsbuild)" | ||
}, | ||
@@ -25,6 +25,20 @@ "repository": { | ||
"devDependencies": { | ||
"@gitzone/tsrun": "^1.0.18", | ||
"@types/node": "^10.5.1", | ||
"tapbundle": "^2.0.0" | ||
} | ||
"@gitzone/tsbuild": "^2.1.17", | ||
"@gitzone/tstest": "^1.0.24", | ||
"@pushrocks/tapbundle": "^3.0.13", | ||
"@types/node": "^12.7.5", | ||
"tslint": "^5.20.0", | ||
"tslint-config-prettier": "^1.18.0" | ||
}, | ||
"files": [ | ||
"ts/*", | ||
"ts_web/*", | ||
"dist/*", | ||
"dist_web/*", | ||
"dist_ts_web/*", | ||
"assets/*", | ||
"cli.js", | ||
"npmextra.json", | ||
"readme.md" | ||
] | ||
} |
# @pushrocks/smartpromise | ||
simple promises and Deferred constructs | ||
## Availabililty and Links | ||
* [npmjs.org (npm package)](https://www.npmjs.com/package/@pushrocks/smartpromise) | ||
* [gitlab.com (source)](https://gitlab.com/pushrocks/smartpromise) | ||
* [github.com (source mirror)](https://github.com/pushrocks/smartpromise) | ||
* [docs (typedoc)](https://pushrocks.gitlab.io/smartpromise/) | ||
- [npmjs.org (npm package)](https://www.npmjs.com/package/@pushrocks/smartpromise) | ||
- [gitlab.com (source)](https://gitlab.com/pushrocks/smartpromise) | ||
- [github.com (source mirror)](https://github.com/pushrocks/smartpromise) | ||
- [docs (typedoc)](https://pushrocks.gitlab.io/smartpromise/) | ||
## Status for master | ||
[![build status](https://gitlab.com/pushrocks/smartpromise/badges/master/build.svg)](https://gitlab.com/pushrocks/smartpromise/commits/master) | ||
@@ -26,3 +29,3 @@ [![coverage report](https://gitlab.com/pushrocks/smartpromise/badges/master/coverage.svg)](https://gitlab.com/pushrocks/smartpromise/commits/master) | ||
```javascript | ||
```typescript | ||
import * as q from '@pushrocks/smartpromise' | ||
@@ -33,7 +36,14 @@ | ||
let myAsyncFunction = (): Promise<string> => { | ||
let done = q.defer<string>() // returns your typical Deferred object | ||
setTimeout(() => { | ||
done.resolve('hi') // will throw type error for other types than string as argument ;) | ||
},6000) | ||
return done.promise | ||
let done = q.defer<string>() // returns your typical Deferred object | ||
setTimeout(() => { | ||
done.resolve('hi') // will throw type error for other types than string as argument ;) | ||
},6000); | ||
console.log(done.status) // logs "pending"; | ||
done.promise.then(() => { | ||
console.log(done.status) // logs "fullfilled" | ||
console.log(done.duration) // logs the milliseconds between instantiation and fullfillment | ||
}) | ||
return done.promise | ||
} | ||
@@ -80,4 +90,4 @@ | ||
> MIT licensed | **©** [Lossless GmbH](https://lossless.gmbh) | ||
| By using this npm module you agree to our [privacy policy](https://lossless.gmbH/privacy.html) | ||
> | By using this npm module you agree to our [privacy policy](https://lossless.gmbH/privacy) | ||
[![repo-footer](https://pushrocks.gitlab.io/assets/repo-footer.svg)](https://maintainedby.lossless.com) | ||
[![repo-footer](https://lossless.gitlab.io/publicrelations/repofooter.svg)](https://maintainedby.lossless.com) |
export interface IResolve<T> { | ||
(value?: T | Promise<T>): void; | ||
(value?: T | PromiseLike<T>): void; | ||
} | ||
@@ -12,10 +12,30 @@ | ||
export class Deferred<T> { | ||
promise: Promise<T>; | ||
resolve: IResolve<T>; | ||
reject: IReject; | ||
status: TDeferredStatus; | ||
public promise: Promise<T>; | ||
public resolve: IResolve<T>; | ||
public reject: IReject; | ||
public status: TDeferredStatus; | ||
public startedAt: number; | ||
public stoppedAt: number; | ||
public get duration(): number { | ||
if (this.stoppedAt) { | ||
return this.stoppedAt - this.startedAt; | ||
} else { | ||
return Date.now() - this.startedAt; | ||
} | ||
} | ||
constructor() { | ||
this.promise = new Promise<T>((resolve, reject) => { | ||
this.resolve = resolve; | ||
this.reject = reject; | ||
this.resolve = (valueArg: T | PromiseLike<T>) => { | ||
this.status = 'fulfilled'; | ||
this.stoppedAt = Date.now(); | ||
resolve(valueArg); | ||
}; | ||
this.reject = (reason: any) => { | ||
this.status = 'rejected'; | ||
this.stoppedAt = Date.now(); | ||
reject(reason); | ||
}; | ||
this.startedAt = Date.now(); | ||
this.status = 'pending'; | ||
@@ -22,0 +42,0 @@ }); |
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
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
91
11233
6
6
172