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

Commit df0abfa

Browse files
committed
fix: pull-stream/throughs/through is not pull-through
1 parent 6a86d55 commit df0abfa

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

src/builder/builder.js

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,8 @@ const UnixFS = require('ipfs-unixfs')
55
const pull = require('pull-stream/pull')
66
const values = require('pull-stream/sources/values')
77
const collect = require('pull-stream/sinks/collect')
8-
const through = require('pull-through')
8+
const through = require('pull-stream/throughs/through')
9+
const pullThrough = require('pull-through')
910
const parallel = require('async/parallel')
1011
const waterfall = require('async/waterfall')
1112
const paraMap = require('pull-paramap')
@@ -153,7 +154,7 @@ module.exports = function builder (createChunker, ipld, createReducer, _options)
153154
}
154155
], callback)
155156
}),
156-
through( // mark as single node if only one single node
157+
pullThrough( // mark as single node if only one single node
157158
function onData (data) {
158159
count++
159160
if (previous) {

0 commit comments

Comments
 (0)