Mirroristas/orbitdb
2
0
Fork 0
mirror of https://github.com/orbitdb/orbitdb.git synced 2025-03-30 15:08:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update dist build

Browse Source
This commit is contained in:
haad 2016-11-03 09:04:56 +01:00
parent b53d9697fe
commit 6889e53105
2 changed files with 46 additions and 39 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

69
dist/orbitdb.js vendored
View File

@ -2848,16 +2848,26 @@ exports.f = __webpack_require__(3);
var drain = __webpack_require__(25)
module.exports = function reduce (reducer, acc, cb) {
return drain(function (data) {
module.exports = function reduce (reducer, acc, cb ) {
if(!cb) cb = acc, acc = null
var sink = drain(function (data) {
acc = reducer(acc, data)
}, function (err) {
cb(err, acc)
})
if (arguments.length === 2)
return function (source) {
source(null, function (end, data) {
//if ended immediately, and no initial...
if(end) return cb(end === true ? null : end)
acc = data; sink(source)
})
}
else
return sink
}
/***/ },
/* 51 */
/***/ function(module, exports, __webpack_require__) {
@ -12868,7 +12878,7 @@ __webpack_require__(48)('observable');
*
* By David Fahlander, david.fahlander@gmail.com
*
* Version 1.5.0, Thu Oct 13 2016
* Version 1.5.1, Tue Nov 01 2016
* www.dexie.com
* Apache License Version 2.0, January 2004, http://www.apache.org/licenses/
*/
@ -14285,14 +14295,14 @@ function rejection(err, uncaughtHandler) {
*
* By David Fahlander, david.fahlander@gmail.com
*
* Version 1.5.0, Thu Oct 13 2016
* Version 1.5.1, Tue Nov 01 2016
*
* http://dexie.org
*
* Apache License Version 2.0, January 2004, http://www.apache.org/licenses/
*/
var DEXIE_VERSION = '1.5.0';
var DEXIE_VERSION = '1.5.1';
var maxString = String.fromCharCode(65535);
var maxKey = function () {
try {
@ -15642,9 +15652,9 @@ function Dexie(dbName, options) {
if (--this._reculock === 0) {
if (!PSD.global) PSD.lockOwnerFor = null;
while (this._blockedFuncs.length > 0 && !this._locked()) {
var fn = this._blockedFuncs.shift();
var fnAndPSD = this._blockedFuncs.shift();
try {
fn();
usePSD(fnAndPSD[1], fnAndPSD[0]);
} catch (e) {}
}
}
@ -15702,30 +15712,27 @@ function Dexie(dbName, options) {
},
_promise: function (mode, fn, bWriteLock) {
var self = this;
return newScope(function () {
var p;
// Read lock always
if (!self._locked()) {
p = self.active ? new Promise(function (resolve, reject) {
if (mode === READWRITE && self.mode !== READWRITE) throw new exceptions.ReadOnly("Transaction is readonly");
if (!self.idbtrans && mode) self.create();
if (bWriteLock) self._lock(); // Write lock if write operation is requested
fn(resolve, reject, self);
}) : rejection(new exceptions.TransactionInactive());
if (self.active && bWriteLock) p.finally(function () {
self._unlock();
});
} else {
// Transaction is write-locked. Wait for mutex.
p = new Promise(function (resolve, reject) {
self._blockedFuncs.push(function () {
self._promise(mode, fn, bWriteLock).then(resolve, reject);
});
});
}
p._lib = true;
return p.uncaught(dbUncaught);
var p = self._locked() ?
// Read lock always. Transaction is write-locked. Wait for mutex.
new Promise(function (resolve, reject) {
self._blockedFuncs.push([function () {
self._promise(mode, fn, bWriteLock).then(resolve, reject);
}, PSD]);
}) : newScope(function () {
var p_ = self.active ? new Promise(function (resolve, reject) {
if (mode === READWRITE && self.mode !== READWRITE) throw new exceptions.ReadOnly("Transaction is readonly");
if (!self.idbtrans && mode) self.create();
if (bWriteLock) self._lock(); // Write lock if write operation is requested
fn(resolve, reject, self);
}) : rejection(new exceptions.TransactionInactive());
if (self.active && bWriteLock) p_.finally(function () {
self._unlock();
});
return p_;
});
p._lib = true;
return p.uncaught(dbUncaught);
},
//

16
dist/orbitdb.min.js vendored
View File

File diff suppressed because one or more lines are too long