Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- var request = require('request');
- var JSONStream = require('JSONStream');
- var Writable = require('readable-stream').Writable;
- request('https://api.github.com/users/substack/repos', {
- headers: { 'User-Agent': 'request' }
- })
- .pipe(JSONStream.parse('*.name'))
- .pipe(ws(3));
- function ws (num) {
- var s = Writable();
- var rows = [];
- var j = 0, i;
- s._write = function (row, enc, next) {
- if (!rows[i = parseInt(j/num, 10)]) rows[i] = [];
- rows[i][j%num] = row.toString();
- j += 1;
- next();
- }
- s.on('finish', function () {
- console.log(rows);
- });
- return s;
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement