Skip to content

Commit

Permalink
bump multileveldown (and levelup)
Browse files Browse the repository at this point in the history
  • Loading branch information
mafintosh committed Jan 9, 2016
1 parent 1d37490 commit 6ed2b8a
Show file tree
Hide file tree
Showing 9 changed files with 21 additions and 21 deletions.
4 changes: 2 additions & 2 deletions example/bulk-insert.js
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
var level = require('../');
var db = level(__dirname + '/data', { encoding: 'json' });
var db = level(__dirname + '/data', { valueEncoding: 'json' });

db.on('leader', function () {
console.log('i am the leader now')
Expand All @@ -16,4 +16,4 @@ function loop () {
})
}

loop()
loop()
2 changes: 1 addition & 1 deletion example/get.js
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
var level = require('../');
var db = level(__dirname + '/data', { encoding: 'json' });
var db = level(__dirname + '/data', { valueEncoding: 'json' });

db.on('leader', function () {
console.log('i am the leader now')
Expand Down
2 changes: 1 addition & 1 deletion example/put.js
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
var level = require('../');
var db = level(__dirname + '/data', { encoding: 'json' });
var db = level(__dirname + '/data', { valueEncoding: 'json' });

db.on('leader', function () {
console.log('i am the leader now')
Expand Down
2 changes: 1 addition & 1 deletion example/read-stream.js
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
var level = require('../');
var db = level(__dirname + '/data', { encoding: 'json' });
var db = level(__dirname + '/data', { valueEncoding: 'json' });

db.on('leader', function () {
console.log('i am the leader now')
Expand Down
2 changes: 1 addition & 1 deletion index.js
Original file line number Diff line number Diff line change
Expand Up @@ -84,7 +84,7 @@ module.exports = function (dir, opts) {

var sock = net.connect(sockPath);
pump(sock, down.createRpcStream(), sock);
down.flush(function () {
client.once('flush', function () {
sock.destroy();
});
}
Expand Down
4 changes: 2 additions & 2 deletions package.json
Original file line number Diff line number Diff line change
Expand Up @@ -5,8 +5,8 @@
"main": "index.js",
"dependencies": {
"has": "^1.0.0",
"level": "^1.2.0",
"multileveldown": "^1.1.0",
"level": "^1.4.0",
"multileveldown": "^2.0.0",
"pump": "^1.0.0"
},
"devDependencies": {
Expand Down
4 changes: 2 additions & 2 deletions readme.markdown
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ This means that if you have 2 programs, 1 that gets:

``` js
var level = require('level-party');
var db = level(__dirname + '/data', { encoding: 'json' });
var db = level(__dirname + '/data', { valueEncoding: 'json' });

setInterval(function () {
db.get('a', function (err, value) {
Expand All @@ -43,7 +43,7 @@ and 1 that puts:

``` js
var level = require('level-party');
var db = level(__dirname + '/data', { encoding: 'json' });
var db = level(__dirname + '/data', { valueEncoding: 'json' });

var n = Math.floor(Math.random() * 100000);

Expand Down
12 changes: 6 additions & 6 deletions test/election.js
Original file line number Diff line number Diff line change
Expand Up @@ -11,32 +11,32 @@ test('failover election party', function (t) {
t.plan(len * (len + 1) / 2);
var pending = keys.length;
var handles = {};

keys.forEach(function (key) {
var h = open(key);
h.on('open', function () {
if (--pending === 0) spinDown();
});
});

function open (key) {
var h = handles[key] = level(datadir, { encoding: 'json' });
var h = handles[key] = level(datadir, { valueEncoding: 'json' });
return h;
}

function spinDown () {
var alive = keys.slice();
(function next () {
if (alive.length === 0) return;

check(alive, function () {
var key = alive.shift();
handles[key].close();
next();
});
})();
}

function check (keys, cb) {
var pending = keys.length;
if (pending === 0) return cb();
Expand Down
10 changes: 5 additions & 5 deletions test/handle.js
Original file line number Diff line number Diff line change
Expand Up @@ -7,19 +7,19 @@ var datadir = path.join(tmpdir, 'level-party-' + Math.random());

test('two handles', function (t) {
t.plan(1);
var adb = level(datadir, { encoding: 'json' });
var bdb = level(datadir, { encoding: 'json' });
var adb = level(datadir, { valueEncoding: 'json' });
var bdb = level(datadir, { valueEncoding: 'json' });
var value = Math.floor(Math.random() * 100000);

adb.put('a', value, function (err) {
if (err) t.fail(err);
var times = 0;

bdb.get('a', function (err, x) {
t.equal(x, value);
});
});

t.on('end', function () {
adb.close();
bdb.close();
Expand Down

0 comments on commit 6ed2b8a

Please sign in to comment.