Highland stream

gistfile1.txt

var _       = require('highland'),
    request = require('request');

// This works but not using the stream approach
// function get(path) {

//     return _(function (push, next) {

//         request(path, function (error, response, body) {
//             // The response itself also contains the body
//             push(error, response);
//             push(null, _.nil);
//         });
//     });
// }

var google = _(request.get('https://www.google.com'));

google
// res is empty array
.map(function (res) {
    console.log(res);
})
// res is empty array
.toArray(function (res) {

    console.log(res);
});