Arsharth/hydrogen-web
1
0
Fork 0
forked from mystiq/hydrogen-web
Code Issues Pull requests Projects Releases Packages Wiki Activity

add flushing manually to prototype

Browse source
This commit is contained in:
Bruno Windels 2020-09-25 16:53:56 +02:00
parent 64290d5ae6
commit 9498524369
2 changed files with 33 additions and 85 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

97
prototypes/idb-promises.html
View file

@ -5,87 +5,20 @@
<meta name="viewport" content="width=device-width, initial-scale=1"> <meta name="viewport" content="width=device-width, initial-scale=1">
</head> </head>
<body> <body>
<!-- <script type="text/javascript" src="promifill.js"></script> --> <script type="text/javascript" src="promifill.js"></script>
<script type="text/javascript">
const PENDING = 1;
const RESOLVED = 2;
const REJECTED = 3;
function noop() {};
function SyncPromise(fn) {
this._listeners = [];
this._value = null;
this._state = PENDING;
fn(this._resolve.bind(this), this._reject.bind(this));
}
SyncPromise.prototype = {
then: function(onResolved, onRejected) {
if (this._state === PENDING) {
this._listeners.push({onRejected: onRejected, onResolved: onResolved});
} else if (this._state === RESOLVED) {
onResolved(this._value);
} else if (this._state === REJECTED) {
onRejected(this._value);
}
return this;
},
catch: function(onRejected) {
return this.then(noop, onRejected);
},
finally: function(onResolved) {
return this.then(onResolved, noop);
},
_chain: function(value) {
if (value && typeof value.then === "function") {
value.then(function(value) {
self._resolve(value);
}, function(err) {
self._reject(err);
});
return true;
} else {
return false;
}
},
_resolve: function(value) {
if (!this._chain(value)) {
this._state = RESOLVED;
this._value = value;
for (var i = 0; i < this._listeners.length; i += 1) {
this._listeners[i].onResolved(value);
}
}
},
_reject: function(err) {
this._state = REJECTED;
this._value = err;
for (var i = 0; i < this._listeners.length; i += 1) {
this._listeners[i].onRejected(err);
}
}
}
SyncPromise.resolve = function(value) {
return new SyncPromise(function(resolve) {
resolve(value);
});
}
SyncPromise.reject = function(value) {
return new SyncPromise(function(_, reject) {
reject(value);
});
}
window.Promise = SyncPromise;
</script>
<!-- <script src="https://cdn.jsdelivr.net/npm/promise-polyfill@8/dist/polyfill.min.js"></script> --> <!-- <script src="https://cdn.jsdelivr.net/npm/promise-polyfill@8/dist/polyfill.min.js"></script> -->
<script type="text/javascript"> <script type="text/javascript">
//window.Promise = Promifill;
function reqAsPromise(req) { function reqAsPromise(req) {
return new Promise(function (resolve, reject) { return new Promise(function (resolve, reject) {
req.onsuccess = function() {resolve(req);}; req.onsuccess = function() {
req.onerror = function(e) {reject(new Error("IDB request failed: " + e.target.error.message));}; resolve(req);
Promise.flushQueue && Promise.flushQueue();
};
req.onerror = function(e) {
reject(new Error("IDB request failed: " + e.target.error.message));
Promise.flushQueue && Promise.flushQueue();
};
}); });
} }
@ -108,8 +41,8 @@
}); });
}, },
openTxn: function(mode, storeName) { openTxn: function(mode, storeName) {
const tx = this._database.transaction([storeName], mode); const txn = this._database.transaction([storeName], mode);
const store = tx.objectStore(storeName); const store = txn.objectStore(storeName);
return Promise.resolve(store); return Promise.resolve(store);
}, },
_createStores: function(db) { _createStores: function(db) {
@ -128,9 +61,13 @@
cursor.continue(); cursor.continue();
} else { } else {
resolve(results); resolve(results);
Promise.flushQueue && Promise.flushQueue();
} }
}; };
request.onerror = function(e) {reject(new Error("IDB request failed: " + e.target.error.message));}; request.onerror = function(e) {
reject(new Error("IDB request failed: " + e.target.error.message));
Promise.flushQueue && Promise.flushQueue();
};
}); });
} }

21
prototypes/promifill.js vendored
View file

@ -267,6 +267,12 @@ var Promifill = /*#__PURE__*/function () {
} }
}); });
} }
}, {
key: "flushQueue",
value: function flushQueue() {
console.log("running promise sync by flushing queue");
schedule.flushQueue();
}
}]); }]);
return Promifill; return Promifill;
@ -379,14 +385,15 @@ var schedule = function () {
while (microtasks.length > 0 && (_microtasks$shift = microtasks.shift(), handler = _microtasks$shift.handler, value = _microtasks$shift.value, _microtasks$shift)) { while (microtasks.length > 0 && (_microtasks$shift = microtasks.shift(), handler = _microtasks$shift.handler, value = _microtasks$shift.value, _microtasks$shift)) {
var _microtasks$shift; var _microtasks$shift;
console.log("running handler with", value);
handler(value); handler(value);
} }
}; };
var Strategy = getStrategy(); var Strategy = getStrategy();
var ctrl = new Strategy(run); var ctrl = new Strategy(run);
return function (observers) {
var scheduleFn = function scheduleFn(observers) {
if (observers.length == 0) { if (observers.length == 0) {
return; return;
} }
@ -395,6 +402,12 @@ var schedule = function () {
observers.length = 0; observers.length = 0;
ctrl.trigger(); ctrl.trigger();
}; };
scheduleFn.flushQueue = function () {
run();
};
return scheduleFn;
}(); }();
var isIterable = function isIterable(subject) { var isIterable = function isIterable(subject) {
@ -428,6 +441,4 @@ var isEmptyIterable = function isEmptyIterable(subject) {
return true; return true;
}; };
//if (!window.Promise) { window.Promifill = Promifill;
window.Promise = Promifill;
//}