Skip to content
This repository was archived by the owner on Dec 2, 2024. It is now read-only.

Commit decff64

Browse files
author
James Halliday
committed
failing bytewise sublevel test hangs on createReadStream()
1 parent 7344bf2 commit decff64

File tree

1 file changed

+41
-0
lines changed

1 file changed

+41
-0
lines changed

test/bytewise_sublevel.js

Lines changed: 41 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,41 @@
1+
var test = require('tape');
2+
var level = require('../');
3+
var path = require('path');
4+
var bsub = require('level-sublevel/bytewise');
5+
var os = require('os');
6+
var tmpdir = os.tmpdir ? os.tmpdir() : os.tmpDir();
7+
var datadir = path.join(tmpdir, 'level-party-' + Math.random());
8+
var bytewise = require('bytewise');
9+
10+
var lopts = { keyEncoding: bytewise, valueEncoding: 'json' };
11+
12+
test('bytewise sublevel', function (t) {
13+
t.plan(5);
14+
var a = level(datadir);
15+
var b = level(datadir);
16+
var adb = bsub(a, lopts);
17+
var bdb = bsub(b, lopts);
18+
var value = Math.floor(Math.random() * 100000);
19+
20+
adb.put([ 'a' ], value, function (err) {
21+
if (err) t.fail(err);
22+
var times = 0;
23+
24+
bdb.get([ 'a' ], function (err, x) {
25+
t.equal(x, value);
26+
});
27+
adb.createReadStream().on('data', function (row) {
28+
t.deepEqual(row.key, [ 'a' ]);
29+
t.deepEqual(row.value, value);
30+
});
31+
bdb.createReadStream().on('data', function (row) {
32+
t.deepEqual(row.key, [ 'a' ]);
33+
t.deepEqual(row.value, value);
34+
});
35+
});
36+
37+
t.on('end', function () {
38+
a.close();
39+
b.close();
40+
});
41+
});

0 commit comments

Comments
 (0)