Comparing version
153
broken.js
@@ -36,5 +36,67 @@ (function (global, factory) { | ||
Promise$1 = function(cb) { | ||
if (cb) { | ||
cb((function(_this) { | ||
_undefined = void 0; | ||
_undefinedString = 'undefined'; | ||
STATE_PENDING = _undefined; | ||
STATE_FULFILLED = 'fulfilled'; | ||
STATE_REJECTED = 'rejected'; | ||
soon = (function() { | ||
var bufferSize, callQueue, cqYield, fq, fqStart; | ||
fq = []; | ||
fqStart = 0; | ||
bufferSize = 1024; | ||
callQueue = function() { | ||
var err; | ||
while (fq.length - fqStart) { | ||
try { | ||
fq[fqStart](); | ||
} catch (error1) { | ||
err = error1; | ||
if (global.console) { | ||
global.console.error(err); | ||
} | ||
} | ||
fq[fqStart++] = _undefined; | ||
if (fqStart === bufferSize) { | ||
fq.splice(0, bufferSize); | ||
fqStart = 0; | ||
} | ||
} | ||
}; | ||
cqYield = (function() { | ||
var dd, mo; | ||
if (typeof MutationObserver !== _undefinedString) { | ||
dd = document.createElement('div'); | ||
mo = new MutationObserver(callQueue); | ||
mo.observe(dd, { | ||
attributes: true | ||
}); | ||
return function() { | ||
dd.setAttribute('a', 0); | ||
}; | ||
} | ||
if (typeof setImmediate !== _undefinedString) { | ||
return function() { | ||
setImmediate(callQueue); | ||
}; | ||
} | ||
return function() { | ||
setTimeout(callQueue, 0); | ||
}; | ||
})(); | ||
return function(fn) { | ||
fq.push(fn); | ||
if (fq.length - fqStart === 1) { | ||
cqYield(); | ||
} | ||
}; | ||
})(); | ||
Promise$1 = function(fn) { | ||
if (fn) { | ||
fn((function(_this) { | ||
return function(arg) { | ||
@@ -81,64 +143,2 @@ return _this.resolve(arg); | ||
STATE_PENDING = void 0; | ||
STATE_FULFILLED = 'fulfilled'; | ||
STATE_REJECTED = 'rejected'; | ||
_undefined = void 0; | ||
_undefinedString = 'undefined'; | ||
soon = (function() { | ||
var bufferSize, callQueue, cqYield, fq, fqStart; | ||
fq = []; | ||
fqStart = 0; | ||
bufferSize = 1024; | ||
cqYield = (function() { | ||
var dd, mo; | ||
if (typeof MutationObserver !== _undefinedString) { | ||
dd = document.createElement('div'); | ||
mo = new MutationObserver(callQueue); | ||
mo.observe(dd, { | ||
attributes: true | ||
}); | ||
return function() { | ||
dd.setAttribute('a', 0); | ||
}; | ||
} | ||
if (typeof setImmediate !== _undefinedString) { | ||
return function() { | ||
setImmediate(callQueue); | ||
}; | ||
} | ||
return function() { | ||
setTimeout(callQueue, 0); | ||
}; | ||
})(); | ||
callQueue = function() { | ||
var err; | ||
while (fq.length - fqStart) { | ||
try { | ||
fq[fqStart](); | ||
} catch (error1) { | ||
err = error1; | ||
if (global.console) { | ||
global.console.error(err); | ||
} | ||
} | ||
fq[fqStart++] = _undefined; | ||
if (fqStart === bufferSize) { | ||
fq.splice(0, bufferSize); | ||
fqStart = 0; | ||
} | ||
} | ||
}; | ||
return function(fn) { | ||
fq.push(fn); | ||
if (fq.length - fqStart === 1) { | ||
cqYield(); | ||
} | ||
}; | ||
})(); | ||
Promise$1.prototype.resolve = function(value) { | ||
@@ -295,27 +295,26 @@ var e, first, me, next; | ||
Promise$1.all = function(pa) { | ||
var rc, results, retP, rp, x; | ||
Promise$1.all = function(ps) { | ||
var i, j, len, p, rc, resolvePromise, results, retP; | ||
results = []; | ||
rc = 0; | ||
retP = new Promise$1; | ||
rp = function(p, i) { | ||
retP = new Promise$1(); | ||
resolvePromise = function(p, i) { | ||
if (!p || typeof p.then !== 'function') { | ||
p = Promise$1.resolve(p); | ||
} | ||
p.then((function(yv) { | ||
p.then(function(yv) { | ||
results[i] = yv; | ||
rc++; | ||
if (rc === pa.length) { | ||
if (rc === ps.length) { | ||
retP.resolve(results); | ||
} | ||
}), function(nv) { | ||
}, function(nv) { | ||
retP.reject(nv); | ||
}); | ||
}; | ||
x = 0; | ||
while (x < pa.length) { | ||
rp(pa[x], x); | ||
x++; | ||
for (i = j = 0, len = ps.length; j < len; i = ++j) { | ||
p = ps[i]; | ||
resolvePromise(p, i); | ||
} | ||
if (!pa.length) { | ||
if (!ps.length) { | ||
retP.resolve(results); | ||
@@ -322,0 +321,0 @@ } |
@@ -32,5 +32,67 @@ 'use strict'; | ||
Promise$1 = function(cb) { | ||
if (cb) { | ||
cb((function(_this) { | ||
_undefined = void 0; | ||
_undefinedString = 'undefined'; | ||
STATE_PENDING = _undefined; | ||
STATE_FULFILLED = 'fulfilled'; | ||
STATE_REJECTED = 'rejected'; | ||
soon = (function() { | ||
var bufferSize, callQueue, cqYield, fq, fqStart; | ||
fq = []; | ||
fqStart = 0; | ||
bufferSize = 1024; | ||
callQueue = function() { | ||
var err; | ||
while (fq.length - fqStart) { | ||
try { | ||
fq[fqStart](); | ||
} catch (error1) { | ||
err = error1; | ||
if (global.console) { | ||
global.console.error(err); | ||
} | ||
} | ||
fq[fqStart++] = _undefined; | ||
if (fqStart === bufferSize) { | ||
fq.splice(0, bufferSize); | ||
fqStart = 0; | ||
} | ||
} | ||
}; | ||
cqYield = (function() { | ||
var dd, mo; | ||
if (typeof MutationObserver !== _undefinedString) { | ||
dd = document.createElement('div'); | ||
mo = new MutationObserver(callQueue); | ||
mo.observe(dd, { | ||
attributes: true | ||
}); | ||
return function() { | ||
dd.setAttribute('a', 0); | ||
}; | ||
} | ||
if (typeof setImmediate !== _undefinedString) { | ||
return function() { | ||
setImmediate(callQueue); | ||
}; | ||
} | ||
return function() { | ||
setTimeout(callQueue, 0); | ||
}; | ||
})(); | ||
return function(fn) { | ||
fq.push(fn); | ||
if (fq.length - fqStart === 1) { | ||
cqYield(); | ||
} | ||
}; | ||
})(); | ||
Promise$1 = function(fn) { | ||
if (fn) { | ||
fn((function(_this) { | ||
return function(arg) { | ||
@@ -77,64 +139,2 @@ return _this.resolve(arg); | ||
STATE_PENDING = void 0; | ||
STATE_FULFILLED = 'fulfilled'; | ||
STATE_REJECTED = 'rejected'; | ||
_undefined = void 0; | ||
_undefinedString = 'undefined'; | ||
soon = (function() { | ||
var bufferSize, callQueue, cqYield, fq, fqStart; | ||
fq = []; | ||
fqStart = 0; | ||
bufferSize = 1024; | ||
cqYield = (function() { | ||
var dd, mo; | ||
if (typeof MutationObserver !== _undefinedString) { | ||
dd = document.createElement('div'); | ||
mo = new MutationObserver(callQueue); | ||
mo.observe(dd, { | ||
attributes: true | ||
}); | ||
return function() { | ||
dd.setAttribute('a', 0); | ||
}; | ||
} | ||
if (typeof setImmediate !== _undefinedString) { | ||
return function() { | ||
setImmediate(callQueue); | ||
}; | ||
} | ||
return function() { | ||
setTimeout(callQueue, 0); | ||
}; | ||
})(); | ||
callQueue = function() { | ||
var err; | ||
while (fq.length - fqStart) { | ||
try { | ||
fq[fqStart](); | ||
} catch (error1) { | ||
err = error1; | ||
if (global.console) { | ||
global.console.error(err); | ||
} | ||
} | ||
fq[fqStart++] = _undefined; | ||
if (fqStart === bufferSize) { | ||
fq.splice(0, bufferSize); | ||
fqStart = 0; | ||
} | ||
} | ||
}; | ||
return function(fn) { | ||
fq.push(fn); | ||
if (fq.length - fqStart === 1) { | ||
cqYield(); | ||
} | ||
}; | ||
})(); | ||
Promise$1.prototype.resolve = function(value) { | ||
@@ -291,27 +291,26 @@ var e, first, me, next; | ||
Promise$1.all = function(pa) { | ||
var rc, results, retP, rp, x; | ||
Promise$1.all = function(ps) { | ||
var i, j, len, p, rc, resolvePromise, results, retP; | ||
results = []; | ||
rc = 0; | ||
retP = new Promise$1; | ||
rp = function(p, i) { | ||
retP = new Promise$1(); | ||
resolvePromise = function(p, i) { | ||
if (!p || typeof p.then !== 'function') { | ||
p = Promise$1.resolve(p); | ||
} | ||
p.then((function(yv) { | ||
p.then(function(yv) { | ||
results[i] = yv; | ||
rc++; | ||
if (rc === pa.length) { | ||
if (rc === ps.length) { | ||
retP.resolve(results); | ||
} | ||
}), function(nv) { | ||
}, function(nv) { | ||
retP.reject(nv); | ||
}); | ||
}; | ||
x = 0; | ||
while (x < pa.length) { | ||
rp(pa[x], x); | ||
x++; | ||
for (i = j = 0, len = ps.length; j < len; i = ++j) { | ||
p = ps[i]; | ||
resolvePromise(p, i); | ||
} | ||
if (!pa.length) { | ||
if (!ps.length) { | ||
retP.resolve(results); | ||
@@ -318,0 +317,0 @@ } |
{ | ||
"name": "broken", | ||
"version": "0.1.6", | ||
"version": "0.1.7", | ||
"description": "Promises are meant to be broken.", | ||
@@ -5,0 +5,0 @@ "main": "dist/broken.js", |
Sorry, the diff of this file is not supported yet
30864
0.71%1246
-0.24%