New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More →
Socket
Sign inDemoInstall
Socket
Sign inDemoInstall

response-iterator

Package Overview
Dependencies
Maintainers
1
Versions
22
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

response-iterator - npm Package Compare versions

Comparing version 0.2.3 to 0.2.4

dist/types/index.d.ts
dist/types/iterators/async.d.ts
dist/types/iterators/nodeStream.d.ts
dist/types/iterators/promise.d.ts
dist/types/iterators/reader.d.ts

69

dist/cjs/index.js
"use strict";
Object.defineProperty(exports, "__esModule", {
value: true
value: true
});
exports["default"] = responseIterator;
var _async = _interopRequireDefault(require("./iterators/async"));
var _nodeStream = _interopRequireDefault(require("./iterators/nodeStream"));
var _promise = _interopRequireDefault(require("./iterators/promise"));
var _reader = _interopRequireDefault(require("./iterators/reader"));
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { "default": obj }; }
var hasIterator = typeof Symbol !== "undefined" && Symbol.asyncIterator;
/**
* @param response A response. Supports fetch, node-fetch, and cross-fetch
*/
module.exports = responseIterator;
var _asyncJs = _interopRequireDefault(require("./iterators/async.js"));
var _nodeStreamJs = _interopRequireDefault(require("./iterators/nodeStream.js"));
var _promiseJs = _interopRequireDefault(require("./iterators/promise.js"));
var _readerJs = _interopRequireDefault(require("./iterators/reader.js"));
function responseIterator(response) {
if (response === undefined) throw new Error("Missing response for responseIterator"); // determine the body
var body = response;
if (response.body) body = response.body; // node-fetch, browser fetch, undici
else if (response.data) body = response.data; // axios
/* c8 ignore start */
else if (response._bodyBlob) body = response._bodyBlob; // cross-fetch
/* c8 ignore stop */
// adapt the body
if (hasIterator && body[Symbol.asyncIterator]) return (0, _async["default"])(body);
/* c8 ignore start */
if (body.getReader) return (0, _reader["default"])(body.getReader());
if (body.stream) return (0, _reader["default"])(body.stream().getReader());
if (body.arrayBuffer) return (0, _promise["default"])(body.arrayBuffer());
if (body.pipe) return (0, _nodeStream["default"])(body);
/* c8 ignore stop */
throw new Error("Unknown body type for responseIterator. Maybe you are not passing a streamable response");
if (response === undefined) throw new Error("Missing response for responseIterator");
// determine the body
var body = response;
if (response.body) body = response.body;
else if (response.data) body = response.data;
else if (response._bodyBlob) body = response._bodyBlob; // cross-fetch
/* c8 ignore stop */ // adapt the body
if (hasIterator && body[Symbol.asyncIterator]) return (0, _asyncJs).default(body);
/* c8 ignore start */ if (body.getReader) return (0, _readerJs).default(body.getReader());
if (body.stream) return (0, _readerJs).default(body.stream().getReader());
if (body.arrayBuffer) return (0, _promiseJs).default(body.arrayBuffer());
if (body.pipe) return (0, _nodeStreamJs).default(body);
/* c8 ignore stop */ throw new Error("Unknown body type for responseIterator. Maybe you are not passing a streamable response");
}
module.exports = exports.default;
//# sourceMappingURL=index.js.map
function _interopRequireDefault(obj) {
return obj && obj.__esModule ? obj : {
default: obj
};
}
var hasIterator = typeof Symbol !== "undefined" && Symbol.asyncIterator;

38

dist/cjs/iterators/async.js
"use strict";
Object.defineProperty(exports, "__esModule", {
value: true
value: true
});
exports["default"] = asyncIterator;
function _defineProperty(obj, key, value) { if (key in obj) { Object.defineProperty(obj, key, { value: value, enumerable: true, configurable: true, writable: true }); } else { obj[key] = value; } return obj; }
module.exports = asyncIterator;
function asyncIterator(source) {
var iterator = source[Symbol.asyncIterator]();
return _defineProperty({
next: function next() {
return iterator.next();
var iterator = source[Symbol.asyncIterator]();
return _defineProperty({
next: function next() {
return iterator.next();
}
}, Symbol.asyncIterator, function() {
return this;
});
}
function _defineProperty(obj, key, value) {
if (key in obj) {
Object.defineProperty(obj, key, {
value: value,
enumerable: true,
configurable: true,
writable: true
});
} else {
obj[key] = value;
}
}, Symbol.asyncIterator, function () {
return this;
});
return obj;
}
module.exports = exports.default;
//# sourceMappingURL=async.js.map

166

dist/cjs/iterators/nodeStream.js
"use strict";
Object.defineProperty(exports, "__esModule", {
value: true
value: true
});
exports["default"] = nodeStreamIterator;
var hasIterator = typeof Symbol !== "undefined" && Symbol.asyncIterator;
/* c8 ignore start */
module.exports = nodeStreamIterator;
function nodeStreamIterator(stream) {
var _cleanup = null;
var error = null;
var done = false;
var data = [];
var waiting = [];
function onData(chunk) {
if (error) return;
if (waiting.length) return waiting.shift()[0]({
value: chunk,
done: false
});
data.push(chunk);
}
function onError(err) {
error = err;
var all = waiting.slice();
all.forEach(function (pair) {
pair[1](err);
});
!_cleanup || _cleanup();
}
function onEnd() {
done = true;
var all = waiting.slice();
all.forEach(function (pair) {
pair[0]({
value: undefined,
done: true
});
});
!_cleanup || _cleanup();
}
_cleanup = function cleanup() {
_cleanup = null;
stream.removeListener("data", onData);
stream.removeListener("error", onError);
stream.removeListener("end", onEnd);
stream.removeListener("finish", onEnd);
stream.removeListener("close", onEnd);
};
stream.on("data", onData);
stream.on("error", onError);
stream.on("end", onEnd);
stream.on("finish", onEnd);
stream.on("close", onEnd);
function getNext() {
return new Promise(function (resolve, reject) {
if (error) return reject(error);
if (data.length) return resolve({
value: data.shift(),
done: false
});
if (done) return resolve({
value: undefined,
done: true
});
waiting.push([resolve, reject]);
});
}
var iterator = {
next: function next() {
return getNext();
var onData = function onData(chunk) {
if (error) return;
if (waiting.length) return waiting.shift()[0]({
value: chunk,
done: false
});
data.push(chunk);
};
var onError = function onError(err) {
error = err;
var all = waiting.slice();
all.forEach(function(pair) {
pair[1](err);
});
!cleanup || cleanup();
};
var onEnd = function onEnd() {
done = true;
var all = waiting.slice();
all.forEach(function(pair) {
pair[0]({
value: undefined,
done: true
});
});
!cleanup || cleanup();
};
var getNext = function getNext() {
return new Promise(function(resolve, reject) {
if (error) return reject(error);
if (data.length) return resolve({
value: data.shift(),
done: false
});
if (done) return resolve({
value: undefined,
done: true
});
waiting.push([
resolve,
reject
]);
});
};
var cleanup = null;
var error = null;
var done = false;
var data = [];
var waiting = [];
cleanup = function() {
cleanup = null;
stream.removeListener("data", onData);
stream.removeListener("error", onError);
stream.removeListener("end", onEnd);
stream.removeListener("finish", onEnd);
stream.removeListener("close", onEnd);
};
stream.on("data", onData);
stream.on("error", onError);
stream.on("end", onEnd);
stream.on("finish", onEnd);
stream.on("close", onEnd);
var iterator = {
next: function next() {
return getNext();
}
};
if (hasIterator) {
iterator[Symbol.asyncIterator] = function() {
return this;
};
}
};
if (hasIterator) {
iterator[Symbol.asyncIterator] = function () {
return this;
};
}
return iterator;
}
/* c8 ignore stop */
module.exports = exports.default;
//# sourceMappingURL=nodeStream.js.map
return iterator;
} /* c8 ignore stop */
var hasIterator = typeof Symbol !== "undefined" && Symbol.asyncIterator;

64

dist/cjs/iterators/promise.js
"use strict";
Object.defineProperty(exports, "__esModule", {
value: true
value: true
});
exports["default"] = promiseIterator;
var hasIterator = typeof Symbol !== "undefined" && Symbol.asyncIterator;
/* c8 ignore start */
module.exports = promiseIterator;
function promiseIterator(promise) {
var resolved = false;
var iterator = {
next: function next() {
if (resolved) return Promise.resolve({
value: undefined,
done: true
});
resolved = true;
return new Promise(function (resolve, reject) {
promise.then(function (value) {
resolve({
value: value,
done: false
});
})["catch"](reject);
});
var resolved = false;
var iterator = {
next: function next() {
if (resolved) return Promise.resolve({
value: undefined,
done: true
});
resolved = true;
return new Promise(function(resolve, reject) {
promise.then(function(value) {
resolve({
value: value,
done: false
});
})["catch"](reject);
});
}
};
if (hasIterator) {
iterator[Symbol.asyncIterator] = function() {
return this;
};
}
};
if (hasIterator) {
iterator[Symbol.asyncIterator] = function () {
return this;
};
}
return iterator;
}
/* c8 ignore stop */
module.exports = exports.default;
//# sourceMappingURL=promise.js.map
return iterator;
} /* c8 ignore stop */
var hasIterator = typeof Symbol !== "undefined" && Symbol.asyncIterator;

38

dist/cjs/iterators/reader.js
"use strict";
Object.defineProperty(exports, "__esModule", {
value: true
value: true
});
exports["default"] = readerIterator;
var hasIterator = typeof Symbol !== "undefined" && Symbol.asyncIterator;
/* c8 ignore start */
module.exports = readerIterator;
function readerIterator(reader) {
var iterator = {
next: function next() {
return reader.read();
var iterator = {
next: function next() {
return reader.read();
}
};
if (hasIterator) {
iterator[Symbol.asyncIterator] = function() {
return this;
};
}
};
if (hasIterator) {
iterator[Symbol.asyncIterator] = function () {
return this;
};
}
return iterator;
}
/* c8 ignore stop */
module.exports = exports.default;
//# sourceMappingURL=reader.js.map
return iterator;
} /* c8 ignore stop */
var hasIterator = typeof Symbol !== "undefined" && Symbol.asyncIterator;

340

dist/umd/response-iterator.js
(function (global, factory) {
typeof exports === 'object' && typeof module !== 'undefined' ? module.exports = factory() :
typeof define === 'function' && define.amd ? define(factory) :
(global = typeof globalThis !== 'undefined' ? globalThis : global || self, global.responseIterator = factory());
typeof exports === 'object' && typeof module !== 'undefined' ? module.exports = factory() :
typeof define === 'function' && define.amd ? define(factory) :
(global = typeof globalThis !== 'undefined' ? globalThis : global || self, global.responseIterator = factory());
})(this, (function () { 'use strict';
function _defineProperty(obj, key, value) {
if (key in obj) {
Object.defineProperty(obj, key, {
value: value,
enumerable: true,
configurable: true,
writable: true
});
} else {
obj[key] = value;
function asyncIterator(source) {
var _a;
var iterator = source[Symbol.asyncIterator]();
return _a = {
next: function () {
return iterator.next();
}
},
_a[Symbol.asyncIterator] = function () {
return this;
},
_a;
}
return obj;
}
function asyncIterator(source) {
var iterator = source[Symbol.asyncIterator]();
return _defineProperty({
next: function next() {
return iterator.next();
}
}, Symbol.asyncIterator, function () {
return this;
});
}
var hasIterator$3 = typeof Symbol !== "undefined" && Symbol.asyncIterator;
/* c8 ignore start */
function nodeStreamIterator(stream) {
var _cleanup = null;
var error = null;
var done = false;
var data = [];
var waiting = [];
function onData(chunk) {
if (error) return;
if (waiting.length) return waiting.shift()[0]({
value: chunk,
done: false
});
data.push(chunk);
}
function onError(err) {
error = err;
var all = waiting.slice();
all.forEach(function (pair) {
pair[1](err);
});
!_cleanup || _cleanup();
}
function onEnd() {
done = true;
var all = waiting.slice();
all.forEach(function (pair) {
pair[0]({
value: undefined,
done: true
});
});
!_cleanup || _cleanup();
}
_cleanup = function cleanup() {
_cleanup = null;
stream.removeListener("data", onData);
stream.removeListener("error", onError);
stream.removeListener("end", onEnd);
stream.removeListener("finish", onEnd);
stream.removeListener("close", onEnd);
};
stream.on("data", onData);
stream.on("error", onError);
stream.on("end", onEnd);
stream.on("finish", onEnd);
stream.on("close", onEnd);
function getNext() {
return new Promise(function (resolve, reject) {
if (error) return reject(error);
if (data.length) return resolve({
value: data.shift(),
done: false
});
if (done) return resolve({
value: undefined,
done: true
});
waiting.push([resolve, reject]);
});
}
var iterator = {
next: function next() {
return getNext();
}
};
if (hasIterator$3) {
iterator[Symbol.asyncIterator] = function () {
return this;
};
}
return iterator;
}
/* c8 ignore stop */
var hasIterator$2 = typeof Symbol !== "undefined" && Symbol.asyncIterator;
/* c8 ignore start */
function promiseIterator(promise) {
var resolved = false;
var iterator = {
next: function next() {
if (resolved) return Promise.resolve({
value: undefined,
done: true
});
resolved = true;
return new Promise(function (resolve, reject) {
promise.then(function (value) {
resolve({
value: value,
done: false
var hasIterator$3 = typeof Symbol !== 'undefined' && Symbol.asyncIterator;
/* c8 ignore start */
function nodeStreamIterator(stream) {
var cleanup = null;
var error = null;
var done = false;
var data = [];
var waiting = [];
function onData(chunk) {
if (error)
return;
if (waiting.length)
return waiting.shift()[0]({ value: chunk, done: false });
data.push(chunk);
}
function onError(err) {
error = err;
var all = waiting.slice();
all.forEach(function (pair) {
pair[1](err);
});
})["catch"](reject);
});
}
};
if (hasIterator$2) {
iterator[Symbol.asyncIterator] = function () {
return this;
};
!cleanup || cleanup();
}
function onEnd() {
done = true;
var all = waiting.slice();
all.forEach(function (pair) {
pair[0]({ value: undefined, done: true });
});
!cleanup || cleanup();
}
cleanup = function () {
cleanup = null;
stream.removeListener('data', onData);
stream.removeListener('error', onError);
stream.removeListener('end', onEnd);
stream.removeListener('finish', onEnd);
stream.removeListener('close', onEnd);
};
stream.on('data', onData);
stream.on('error', onError);
stream.on('end', onEnd);
stream.on('finish', onEnd);
stream.on('close', onEnd);
function getNext() {
return new Promise(function (resolve, reject) {
if (error)
return reject(error);
if (data.length)
return resolve({ value: data.shift(), done: false });
if (done)
return resolve({ value: undefined, done: true });
waiting.push([resolve, reject]);
});
}
var iterator = {
next: function () {
return getNext();
},
};
if (hasIterator$3) {
iterator[Symbol.asyncIterator] = function () {
return this;
};
}
return iterator;
}
/* c8 ignore stop */
return iterator;
}
/* c8 ignore stop */
var hasIterator$1 = typeof Symbol !== "undefined" && Symbol.asyncIterator;
/* c8 ignore start */
function readerIterator(reader) {
var iterator = {
next: function next() {
return reader.read();
}
};
if (hasIterator$1) {
iterator[Symbol.asyncIterator] = function () {
return this;
};
var hasIterator$2 = typeof Symbol !== 'undefined' && Symbol.asyncIterator;
/* c8 ignore start */
function promiseIterator(promise) {
var resolved = false;
var iterator = {
next: function () {
if (resolved)
return Promise.resolve({ value: undefined, done: true });
resolved = true;
return new Promise(function (resolve, reject) {
promise
.then(function (value) {
resolve({ value: value, done: false });
})
.catch(reject);
});
},
};
if (hasIterator$2) {
iterator[Symbol.asyncIterator] = function () {
return this;
};
}
return iterator;
}
return iterator;
}
/* c8 ignore stop */
var hasIterator = typeof Symbol !== "undefined" && Symbol.asyncIterator;
/**
* @param response A response. Supports fetch, node-fetch, and cross-fetch
*/
function responseIterator(response) {
if (response === undefined) throw new Error("Missing response for responseIterator"); // determine the body
var body = response;
if (response.body) body = response.body; // node-fetch, browser fetch, undici
else if (response.data) body = response.data; // axios
/* c8 ignore start */
else if (response._bodyBlob) body = response._bodyBlob; // cross-fetch
/* c8 ignore stop */
// adapt the body
if (hasIterator && body[Symbol.asyncIterator]) return asyncIterator(body);
var hasIterator$1 = typeof Symbol !== 'undefined' && Symbol.asyncIterator;
/* c8 ignore start */
if (body.getReader) return readerIterator(body.getReader());
if (body.stream) return readerIterator(body.stream().getReader());
if (body.arrayBuffer) return promiseIterator(body.arrayBuffer());
if (body.pipe) return nodeStreamIterator(body);
function readerIterator(reader) {
var iterator = {
next: function () {
return reader.read();
},
};
if (hasIterator$1) {
iterator[Symbol.asyncIterator] = function () {
return this;
};
}
return iterator;
}
/* c8 ignore stop */
throw new Error("Unknown body type for responseIterator. Maybe you are not passing a streamable response");
}
var hasIterator = typeof Symbol !== 'undefined' && Symbol.asyncIterator;
/**
* @param response A response. Supports fetch, node-fetch, and cross-fetch
*/
function responseIterator(response) {
if (response === undefined)
throw new Error('Missing response for responseIterator');
// determine the body
var body = response;
if (response.body)
body = response.body;
// node-fetch, browser fetch, undici
else if (response.data)
body = response.data;
// axios
/* c8 ignore start */ else if (response._bodyBlob)
body = response._bodyBlob; // cross-fetch
/* c8 ignore stop */
// adapt the body
if (hasIterator && body[Symbol.asyncIterator])
return asyncIterator(body);
/* c8 ignore start */
if (body.getReader)
return readerIterator(body.getReader());
if (body.stream)
return readerIterator(body.stream().getReader());
if (body.arrayBuffer)
return promiseIterator(body.arrayBuffer());
if (body.pipe)
return nodeStreamIterator(body);
/* c8 ignore stop */
throw new Error('Unknown body type for responseIterator. Maybe you are not passing a streamable response');
}
return responseIterator;
return responseIterator;
}));
//# sourceMappingURL=response-iterator.js.map

2

dist/umd/response-iterator.min.js

@@ -1,2 +0,2 @@

!function(e,n){"object"==typeof exports&&"undefined"!=typeof module?module.exports=n():"function"==typeof define&&define.amd?define(n):(e="undefined"!=typeof globalThis?globalThis:e||self).responseIterator=n()}(this,(function(){"use strict";function e(e){var n,r,o,t=e[Symbol.asyncIterator]();return n={next:function(){return t.next()}},r=Symbol.asyncIterator,o=function(){return this},r in n?Object.defineProperty(n,r,{value:o,enumerable:!0,configurable:!0,writable:!0}):n[r]=o,n}var n="undefined"!=typeof Symbol&&Symbol.asyncIterator;function r(e){var r=null,o=null,t=!1,i=[],a=[];function u(e){if(!o)return a.length?a.shift()[0]({value:e,done:!1}):void i.push(e)}function f(e){o=e,a.slice().forEach((function(n){n[1](e)})),!r||r()}function s(){t=!0,a.slice().forEach((function(e){e[0]({value:void 0,done:!0})})),!r||r()}r=function(){r=null,e.removeListener("data",u),e.removeListener("error",f),e.removeListener("end",s),e.removeListener("finish",s),e.removeListener("close",s)},e.on("data",u),e.on("error",f),e.on("end",s),e.on("finish",s),e.on("close",s);var l={next:function(){return new Promise((function(e,n){return o?n(o):i.length?e({value:i.shift(),done:!1}):t?e({value:void 0,done:!0}):void a.push([e,n])}))}};return n&&(l[Symbol.asyncIterator]=function(){return this}),l}var o="undefined"!=typeof Symbol&&Symbol.asyncIterator;var t="undefined"!=typeof Symbol&&Symbol.asyncIterator;function i(e){var n={next:function(){return e.read()}};return t&&(n[Symbol.asyncIterator]=function(){return this}),n}var a="undefined"!=typeof Symbol&&Symbol.asyncIterator;return function(n){if(void 0===n)throw new Error("Missing response for responseIterator");var t,u,f,s=n;if(n.body?s=n.body:n.data?s=n.data:n._bodyBlob&&(s=n._bodyBlob),a&&s[Symbol.asyncIterator])return e(s);if(s.getReader)return i(s.getReader());if(s.stream)return i(s.stream().getReader());if(s.arrayBuffer)return t=s.arrayBuffer(),u=!1,f={next:function(){return u?Promise.resolve({value:void 0,done:!0}):(u=!0,new Promise((function(e,n){t.then((function(n){e({value:n,done:!1})})).catch(n)})))}},o&&(f[Symbol.asyncIterator]=function(){return this}),f;if(s.pipe)return r(s);throw new Error("Unknown body type for responseIterator. Maybe you are not passing a streamable response")}}));
!function(e,n){"object"==typeof exports&&"undefined"!=typeof module?module.exports=n():"function"==typeof define&&define.amd?define(n):(e="undefined"!=typeof globalThis?globalThis:e||self).responseIterator=n()}(this,(function(){"use strict";var e="undefined"!=typeof Symbol&&Symbol.asyncIterator;function n(n){var r=null,o=null,t=!1,i=[],a=[];function u(e){if(!o)return a.length?a.shift()[0]({value:e,done:!1}):void i.push(e)}function f(e){o=e,a.slice().forEach((function(n){n[1](e)})),!r||r()}function s(){t=!0,a.slice().forEach((function(e){e[0]({value:void 0,done:!0})})),!r||r()}r=function(){r=null,n.removeListener("data",u),n.removeListener("error",f),n.removeListener("end",s),n.removeListener("finish",s),n.removeListener("close",s)},n.on("data",u),n.on("error",f),n.on("end",s),n.on("finish",s),n.on("close",s);var d={next:function(){return new Promise((function(e,n){return o?n(o):i.length?e({value:i.shift(),done:!1}):t?e({value:void 0,done:!0}):void a.push([e,n])}))}};return e&&(d[Symbol.asyncIterator]=function(){return this}),d}var r="undefined"!=typeof Symbol&&Symbol.asyncIterator;var o="undefined"!=typeof Symbol&&Symbol.asyncIterator;function t(e){var n={next:function(){return e.read()}};return o&&(n[Symbol.asyncIterator]=function(){return this}),n}var i="undefined"!=typeof Symbol&&Symbol.asyncIterator;return function(e){if(void 0===e)throw new Error("Missing response for responseIterator");var o,a,u=e;if(e.body?u=e.body:e.data?u=e.data:e._bodyBlob&&(u=e._bodyBlob),i&&u[Symbol.asyncIterator])return a=u[Symbol.asyncIterator](),(o={next:function(){return a.next()}})[Symbol.asyncIterator]=function(){return this},o;if(u.getReader)return t(u.getReader());if(u.stream)return t(u.stream().getReader());if(u.arrayBuffer)return function(e){var n=!1,o={next:function(){return n?Promise.resolve({value:void 0,done:!0}):(n=!0,new Promise((function(n,r){e.then((function(e){n({value:e,done:!1})})).catch(r)})))}};return r&&(o[Symbol.asyncIterator]=function(){return this}),o}(u.arrayBuffer());if(u.pipe)return n(u);throw new Error("Unknown body type for responseIterator. Maybe you are not passing a streamable response")}}));
//# sourceMappingURL=response-iterator.min.js.map

9

package.json
{
"name": "response-iterator",
"description": "Creates an async iterator for a variety of inputs in the browser and node. Supports fetch, node-fetch, and cross-fetch",
"version": "0.2.3",
"version": "0.2.4",
"author": {

@@ -64,3 +64,3 @@ "email": "kmalakoff@gmail.com",

"readable-stream-3": "npm:readable-stream@4.0.0",
"ts-dev-stack": "^0.2.1",
"ts-dev-stack": "^0.3.3",
"undici": "^5.5.1"

@@ -76,8 +76,9 @@ },

"require": "./dist/cjs/index.js",
"types": "./dist/esm/index.d.ts"
"types": "./dist/types/index.d.ts"
},
"./*": "./*"
},
"types": "dist/esm/index.d.ts",
"source": "src/index.ts",
"types": "dist/types/index.d.ts",
"unpkg": "dist/umd/response-iterator.js"
}

14

README.md

@@ -9,7 +9,7 @@ ## response-iterator

// import "isomorphic-fetch"; // node only
import responseIterator from "response-iterator";
import responseIterator from 'response-iterator';
const res = await fetch("https://raw.githubusercontent.com/kmalakoff/response-iterator/master/package.json");
const res = await fetch('https://raw.githubusercontent.com/kmalakoff/response-iterator/master/package.json');
let data = "";
let data = '';
for await (const chunk of responseIterator(res)) {

@@ -24,8 +24,8 @@ data += chunk;

```typescript
import crossFetch from "cross-fetch";
import responseIterator from "response-iterator";
import crossFetch from 'cross-fetch';
import responseIterator from 'response-iterator';
const res = await crossFetch("https://raw.githubusercontent.com/kmalakoff/response-iterator/master/package.json");
const res = await crossFetch('https://raw.githubusercontent.com/kmalakoff/response-iterator/master/package.json');
let data = "";
let data = '';
for await (const chunk of responseIterator(res)) {

@@ -32,0 +32,0 @@ data += chunk;

dist/cjs/index.d.ts
dist/cjs/iterators/async.d.ts
dist/cjs/iterators/nodeStream.d.ts
dist/cjs/iterators/promise.d.ts
dist/cjs/iterators/reader.d.ts
dist/esm/index.d.ts
dist/esm/iterators/async.d.ts
dist/esm/iterators/nodeStream.d.ts
dist/esm/iterators/promise.d.ts
dist/esm/iterators/reader.d.ts
dist/cjs/index.js.map

Sorry, the diff of this file is not supported yet

dist/cjs/iterators/async.js.map

Sorry, the diff of this file is not supported yet

dist/cjs/iterators/nodeStream.js.map

Sorry, the diff of this file is not supported yet

dist/cjs/iterators/promise.js.map

Sorry, the diff of this file is not supported yet

dist/cjs/iterators/reader.js.map

Sorry, the diff of this file is not supported yet

dist/esm/index.mjs

Sorry, the diff of this file is not supported yet

dist/esm/index.mjs.map

Sorry, the diff of this file is not supported yet

dist/esm/iterators/async.mjs

Sorry, the diff of this file is not supported yet

dist/esm/iterators/async.mjs.map

Sorry, the diff of this file is not supported yet

dist/esm/iterators/nodeStream.mjs

Sorry, the diff of this file is not supported yet

dist/esm/iterators/nodeStream.mjs.map

Sorry, the diff of this file is not supported yet

dist/esm/iterators/promise.mjs

Sorry, the diff of this file is not supported yet

dist/esm/iterators/promise.mjs.map

Sorry, the diff of this file is not supported yet

dist/esm/iterators/reader.mjs

Sorry, the diff of this file is not supported yet

dist/esm/iterators/reader.mjs.map

Sorry, the diff of this file is not supported yet

dist/umd/response-iterator.js.map

Sorry, the diff of this file is not supported yet

dist/umd/response-iterator.min.js.map

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

About

Packages

npm

Go

Maven

PyPI

Rubygems

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc