Skip to content

Commit 965d8df

Browse files
committed
refactor: simplify
1 parent 151a6f4 commit 965d8df

File tree

3 files changed

+11
-15
lines changed

3 files changed

+11
-15
lines changed

binding.cc

Lines changed: 2 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1327,7 +1327,6 @@ NAPI_METHOD(iterator_nextv) {
13271327
}
13281328
};
13291329

1330-
auto status = rocksdb::Status::OK();
13311330
while (true) {
13321331
if (!iterator->first_) {
13331332
iterator->Next();
@@ -1336,9 +1335,8 @@ NAPI_METHOD(iterator_nextv) {
13361335
}
13371336

13381337
if (!iterator->Valid() || !iterator->Increment()) {
1339-
status = iterator->Status();
13401338
state.finished = true;
1341-
break;
1339+
return iterator->Status();
13421340
}
13431341

13441342
if (iterator->keys_ && iterator->values_) {
@@ -1353,13 +1351,10 @@ NAPI_METHOD(iterator_nextv) {
13531351
}
13541352

13551353
if (bytesRead > iterator->highWaterMarkBytes_ || state.sizes.size() / 2 >= count) {
1356-
status = rocksdb::Status::OK();
13571354
state.finished = false;
1358-
break;
1355+
return rocksdb::Status::OK();
13591356
}
13601357
}
1361-
1362-
return status;
13631358
},
13641359
[=](auto& state, auto env, auto& argv) {
13651360
argv.resize(4);

index.js

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -158,27 +158,28 @@ class RocksLevel extends AbstractLevel {
158158
} else {
159159
data ??= Buffer.alloc(0)
160160
sizes ??= Buffer.alloc(0)
161-
const val = []
161+
162+
const rows = []
162163
let offset = 0
163164
const sizes32 = new Int32Array(sizes.buffer, sizes.byteOffset, sizes.byteLength / 4)
164165
for (const size of sizes32) {
165166
if (size < 0) {
166-
val.push(undefined)
167+
rows.push(undefined)
167168
} else {
168169
if (!valueEncoding || valueEncoding === 'buffer') {
169-
val.push(data.subarray(offset, offset + size))
170+
rows.push(data.subarray(offset, offset + size))
170171
} else if (valueEncoding === 'slice') {
171-
val.push({ buffer: data, byteOffset: offset, byteLength: size })
172+
rows.push({ buffer: data, byteOffset: offset, byteLength: size })
172173
} else {
173-
val.push(data.toString(valueEncoding, offset, offset + size))
174+
rows.push(data.toString(valueEncoding, offset, offset + size))
174175
}
175176
offset += size
176177
if (offset & 0x7) {
177178
offset = (offset | 0x7) + 1
178179
}
179180
}
180181
}
181-
callback(null, val)
182+
callback(null, rows)
182183
}
183184
this[kUnref]()
184185
})

util.js

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,14 +1,14 @@
11
'use strict'
22

33
function handleNextv (err, sizes, buffer, finished, options, callback) {
4+
const { keyEncoding, valueEncoding } = options ?? {}
5+
46
if (err) {
57
callback(err)
68
} else {
79
buffer ??= Buffer.alloc(0)
810
sizes ??= Buffer.alloc(0)
911

10-
const { keyEncoding, valueEncoding } = options ?? {}
11-
1212
const rows = []
1313
let offset = 0
1414
const sizes32 = new Int32Array(sizes.buffer, sizes.byteOffset, sizes.byteLength / 4)

0 commit comments

Comments
 (0)