diff --git a/packages/ipfs-grpc-server/src/endpoints/add.js b/packages/ipfs-grpc-server/src/endpoints/add.js index 5f39f01413..c31a8d3b1a 100644 --- a/packages/ipfs-grpc-server/src/endpoints/add.js +++ b/packages/ipfs-grpc-server/src/endpoints/add.js @@ -56,7 +56,6 @@ module.exports = function grpcAdd (ipfs, options = {}) { if (!stream) { // start of new file - // @ts-ignore stream = streams[index] = pushable() fileInputStream.push({ @@ -83,7 +82,7 @@ module.exports = function grpcAdd (ipfs, options = {}) { fileInputStream.end(err) } finally { // clean up any open streams - streams.filter(Boolean).forEach(stream => stream.end()) + streams.forEach(stream => stream && stream.end()) } }, 0)