@pushrocks/smartpromise
Advanced tools
Comparing version 2.0.5 to 3.0.0
@@ -1,3 +0,1 @@ | ||
/// <reference types="node" /> | ||
import * as util from 'util'; | ||
export interface IResolve<T> { | ||
@@ -26,3 +24,6 @@ (value?: T | Promise<T>): void; | ||
export declare let rejectedPromise: (err: any) => Promise<never>; | ||
export declare let promisify: typeof util.promisify; | ||
export declare let map: <T>(inputArg: T[], functionArg: any) => Promise<any[]>; | ||
interface IAsyncFunction<T> { | ||
(someArg: T): Promise<T>; | ||
} | ||
export declare let map: <T>(inputArg: T[], functionArg: IAsyncFunction<T>) => Promise<any[]>; | ||
export {}; |
@@ -11,3 +11,2 @@ "use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
const util = require("util"); | ||
class Deferred { | ||
@@ -38,9 +37,7 @@ constructor() { | ||
}; | ||
exports.promisify = util.promisify; | ||
exports.map = (inputArg, functionArg) => __awaiter(this, void 0, void 0, function* () { | ||
let promisifedFunction = exports.promisify(functionArg); | ||
let promiseArray = []; | ||
let resultArray = []; | ||
for (let item of inputArg) { | ||
let promise = promisifedFunction(item); | ||
let promise = functionArg(item); | ||
promiseArray.push(promise); | ||
@@ -54,2 +51,2 @@ promise.then(x => { | ||
}); | ||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9pbmRleC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOzs7Ozs7Ozs7O0FBQUEsNkJBQTZCO0FBWTdCO0lBS0U7UUFDRSxJQUFJLENBQUMsT0FBTyxHQUFHLElBQUksT0FBTyxDQUFJLENBQUMsT0FBTyxFQUFFLE1BQU0sRUFBRSxFQUFFO1lBQ2hELElBQUksQ0FBQyxPQUFPLEdBQUcsT0FBTyxDQUFDO1lBQ3ZCLElBQUksQ0FBQyxNQUFNLEdBQUcsTUFBTSxDQUFDO1lBQ3JCLElBQUksQ0FBQyxNQUFNLEdBQUcsU0FBUyxDQUFDO1FBQzFCLENBQUMsQ0FBQyxDQUFDO0lBQ0wsQ0FBQztDQUNGO0FBWkQsNEJBWUM7QUFFVSxRQUFBLEtBQUssR0FBRyxHQUFNLEVBQUU7SUFDekIsT0FBTyxJQUFJLFFBQVEsRUFBSyxDQUFDO0FBQzNCLENBQUMsQ0FBQztBQUVGOztHQUVHO0FBQ1EsUUFBQSxlQUFlLEdBQUcsQ0FBSSxLQUFTLEVBQWMsRUFBRTtJQUN4RCxPQUFPLE9BQU8sQ0FBQyxPQUFPLENBQUMsS0FBSyxDQUFDLENBQUM7QUFDaEMsQ0FBQyxDQUFDO0FBRUY7O0dBRUc7QUFDUSxRQUFBLGVBQWUsR0FBRyxHQUFHLENBQUMsRUFBRTtJQUNqQyxPQUFPLE9BQU8sQ0FBQyxNQUFNLENBQUMsR0FBRyxDQUFDLENBQUM7QUFDN0IsQ0FBQyxDQUFDO0FBRVMsUUFBQSxTQUFTLEdBQUcsSUFBSSxDQUFDLFNBQVMsQ0FBQztBQUUzQixRQUFBLEdBQUcsR0FBRyxDQUFVLFFBQWEsRUFBRSxXQUFXLEVBQUUsRUFBRTtJQUN2RCxJQUFJLGtCQUFrQixHQUFHLGlCQUFTLENBQUMsV0FBVyxDQUFDLENBQUM7SUFDaEQsSUFBSSxZQUFZLEdBQW1CLEVBQUUsQ0FBQztJQUN0QyxJQUFJLFdBQVcsR0FBRyxFQUFFLENBQUM7SUFDckIsS0FBSyxJQUFJLElBQUksSUFBSSxRQUFRLEVBQUU7UUFDekIsSUFBSSxPQUFPLEdBQWlCLGtCQUFrQixDQUFDLElBQUksQ0FBQyxDQUFDO1FBQ3JELFlBQVksQ0FBQyxJQUFJLENBQUMsT0FBTyxDQUFDLENBQUM7UUFDM0IsT0FBTyxDQUFDLElBQUksQ0FBQyxDQUFDLENBQUMsRUFBRTtZQUNmLFdBQVcsQ0FBQyxJQUFJLENBQUMsQ0FBQyxDQUFDLENBQUM7UUFDdEIsQ0FBQyxDQUFDLENBQUM7S0FDSjtJQUNELE1BQU0sT0FBTyxDQUFDLEdBQUcsQ0FBQyxZQUFZLENBQUMsQ0FBQztJQUNoQyxPQUFPLFdBQVcsQ0FBQztBQUNyQixDQUFDLENBQUEsQ0FBQyJ9 | ||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9pbmRleC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOzs7Ozs7Ozs7O0FBVUE7SUFLRTtRQUNFLElBQUksQ0FBQyxPQUFPLEdBQUcsSUFBSSxPQUFPLENBQUksQ0FBQyxPQUFPLEVBQUUsTUFBTSxFQUFFLEVBQUU7WUFDaEQsSUFBSSxDQUFDLE9BQU8sR0FBRyxPQUFPLENBQUM7WUFDdkIsSUFBSSxDQUFDLE1BQU0sR0FBRyxNQUFNLENBQUM7WUFDckIsSUFBSSxDQUFDLE1BQU0sR0FBRyxTQUFTLENBQUM7UUFDMUIsQ0FBQyxDQUFDLENBQUM7SUFDTCxDQUFDO0NBQ0Y7QUFaRCw0QkFZQztBQUVVLFFBQUEsS0FBSyxHQUFHLEdBQU0sRUFBRTtJQUN6QixPQUFPLElBQUksUUFBUSxFQUFLLENBQUM7QUFDM0IsQ0FBQyxDQUFDO0FBRUY7O0dBRUc7QUFDUSxRQUFBLGVBQWUsR0FBRyxDQUFJLEtBQVMsRUFBYyxFQUFFO0lBQ3hELE9BQU8sT0FBTyxDQUFDLE9BQU8sQ0FBQyxLQUFLLENBQUMsQ0FBQztBQUNoQyxDQUFDLENBQUM7QUFFRjs7R0FFRztBQUNRLFFBQUEsZUFBZSxHQUFHLEdBQUcsQ0FBQyxFQUFFO0lBQ2pDLE9BQU8sT0FBTyxDQUFDLE1BQU0sQ0FBQyxHQUFHLENBQUMsQ0FBQztBQUM3QixDQUFDLENBQUM7QUFNUyxRQUFBLEdBQUcsR0FBRyxDQUFVLFFBQWEsRUFBRSxXQUE4QixFQUFHLEVBQUU7SUFDM0UsSUFBSSxZQUFZLEdBQW1CLEVBQUUsQ0FBQztJQUN0QyxJQUFJLFdBQVcsR0FBRyxFQUFFLENBQUM7SUFDckIsS0FBSyxJQUFJLElBQUksSUFBSSxRQUFRLEVBQUU7UUFDekIsSUFBSSxPQUFPLEdBQWlCLFdBQVcsQ0FBQyxJQUFJLENBQUMsQ0FBQztRQUM5QyxZQUFZLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQyxDQUFDO1FBQzNCLE9BQU8sQ0FBQyxJQUFJLENBQUMsQ0FBQyxDQUFDLEVBQUU7WUFDZixXQUFXLENBQUMsSUFBSSxDQUFDLENBQUMsQ0FBQyxDQUFDO1FBQ3RCLENBQUMsQ0FBQyxDQUFDO0tBQ0o7SUFDRCxNQUFNLE9BQU8sQ0FBQyxHQUFHLENBQUMsWUFBWSxDQUFDLENBQUM7SUFDaEMsT0FBTyxXQUFXLENBQUM7QUFDckIsQ0FBQyxDQUFBLENBQUMifQ== |
{ | ||
"name": "@pushrocks/smartpromise", | ||
"private": false, | ||
"version": "2.0.5", | ||
"version": "3.0.0", | ||
"description": "dropin replacement for q", | ||
@@ -6,0 +6,0 @@ "main": "dist/index.js", |
import { expect, tap } from 'tapbundle'; | ||
import * as q from '../ts/index'; | ||
let myCallback = (someValue1: string, cb?) => { | ||
cb(null, someValue1); | ||
}; | ||
tap.test('should return a Deferred for .defer()', async () => { | ||
@@ -23,12 +19,6 @@ let myDeferred = q.defer(); | ||
tap.test('should promisify a callback', async () => { | ||
let myPromisified = q.promisify(myCallback); | ||
let expectPromise = expect(myPromisified('hi')).to.eventually.equal('hi'); | ||
return await expectPromise; | ||
}); | ||
tap.test('should map callbacks', async () => { | ||
let inputArray = ['hi', 'awesome']; | ||
let myPromisified = q.promisify(myCallback); | ||
let expectPromise = expect(q.map(inputArray, myPromisified)).to.eventually.deep.equal(inputArray); | ||
const myPromisified = async (myInput) => { return myInput }; | ||
const expectPromise = expect(q.map(inputArray, myPromisified)).to.eventually.deep.equal(inputArray); | ||
return expectPromise; | ||
@@ -35,0 +25,0 @@ }); |
@@ -1,3 +0,1 @@ | ||
import * as util from 'util'; | ||
export interface IResolve<T> { | ||
@@ -45,10 +43,11 @@ (value?: T | Promise<T>): void; | ||
export let promisify = util.promisify; | ||
interface IAsyncFunction<T> { | ||
(someArg: T):Promise<T> | ||
} | ||
export let map = async <T>(inputArg: T[], functionArg) => { | ||
let promisifedFunction = promisify(functionArg); | ||
export let map = async <T>(inputArg: T[], functionArg: IAsyncFunction<T> ) => { | ||
let promiseArray: Promise<any>[] = []; | ||
let resultArray = []; | ||
for (let item of inputArg) { | ||
let promise: Promise<any> = promisifedFunction(item); | ||
let promise: Promise<any> = functionArg(item); | ||
promiseArray.push(promise); | ||
@@ -55,0 +54,0 @@ promise.then(x => { |
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
12814
159