Skip to content
This repository was archived by the owner on Mar 10, 2020. It is now read-only.

Commit 17967c1

Browse files
achingbraindaviddias
authored andcommitted
feat: Add offset/length arguments to files.cat
1 parent 1f889d3 commit 17967c1

File tree

3 files changed

+18
-3
lines changed

3 files changed

+18
-3
lines changed

Diff for: src/files/cat-pull-stream.js

+6-1
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,12 @@ module.exports = (send) => {
1919
}
2020
}
2121

22-
send({ path: 'cat', args: hash, buffer: opts.buffer }, (err, stream) => {
22+
const query = {
23+
offset: opts.offset,
24+
length: opts.length
25+
}
26+
27+
send({ path: 'cat', args: hash, buffer: opts.buffer, qs: query }, (err, stream) => {
2328
if (err) { return p.end(err) }
2429

2530
p.resolve(toPull(stream))

Diff for: src/files/cat-readable-stream.js

+6-1
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,12 @@ module.exports = (send) => {
1919
}
2020
}
2121

22-
send({ path: 'cat', args: hash, buffer: opts.buffer }, (err, stream) => {
22+
const query = {
23+
offset: opts.offset,
24+
length: opts.length
25+
}
26+
27+
send({ path: 'cat', args: hash, buffer: opts.buffer, qs: query }, (err, stream) => {
2328
if (err) { return pt.destroy(err) }
2429

2530
pump(stream, pt)

Diff for: src/files/cat.js

+6-1
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,12 @@ module.exports = (send) => {
2020
}
2121
}
2222

23-
send({ path: 'cat', args: hash, buffer: opts.buffer }, (err, stream) => {
23+
const query = {
24+
offset: opts.offset,
25+
length: opts.length
26+
}
27+
28+
send({ path: 'cat', args: hash, buffer: opts.buffer, qs: query }, (err, stream) => {
2429
if (err) { return callback(err) }
2530

2631
stream.pipe(bl((err, data) => {

0 commit comments

Comments
 (0)