pipe function in Node and http.get

2019-06-17 05:41发布

I am learning node under workshops from nodeschool. name of workshop is learnyounode, question number 8. HTTP COLLECT.

Question was: Write a program that performs an HTTP GET request to a URL provided to you as the first command-line argument. Collect all data from the server (not just the first "data" event) and then write two lines to the console (stdout). The first line you write should just be an integer representing the number of characters received from the server. The second line should contain the complete String of characters sent by the server.

The answer i submitted was as follows.

var http = require('http');
var url = process.argv[2];
http.get(url,function(res){
    var body = '';
    res.on('error',function(err){
        console.error(err);
    })
    res.on('data',function(chunk){
        body+=chunk.toString();
    });
    res.on('end',function(){
        console.log(body.length);
        console.log(body);
    });
});

while the answer they provided was,

var http = require('http')
var bl = require('bl')
http.get(process.argv[2], function (response) {
  response.pipe(bl(function (err, data) {
    if (err)
      return console.error(err)
    data = data.toString()
    console.log(data.length)
    console.log(data)
  }))
})


I would like to know the difference between these two codes. and please explain how http.get() and pipe works ...

1条回答
Bombasti
2楼-- · 2019-06-17 06:01

The only difference is how you two handled the response. You handled the response chunk by chunk and appended the string equivalent to body. They used pipe to send a readable stream response and send it to a writable stream bl (buffer list) which can wait until the readable stream is done before proceeding. While you subscribed to the emitter of 'data' to handle the response chunks, bl does that under the covers.

pipe is a function called on a readable stream that is passed a parameter of a writable stream.

Edit: I just noticed the date of your post. It's odd no one answered this...

查看更多
登录 后发表回答