Skip to content

Instantly share code, notes, and snippets.

@cranic

cranic/gist:9958202

Created April 3, 2014 16:47
Show Gist options
  • Save cranic/9958202 to your computer and use it in GitHub Desktop.
Save cranic/9958202 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
gistfile1.js
var request = require('request');
var data = [];
var stream = request.get('http://url_do_stream');
stream.on('data', function(buff){
// Recebemos um buffer de dados
// vamos adicionar aos buffers
data.push(buff);
// Precisamos verificar se o
// último caractere é o delimitador
// aqui vou usar o \n como delimitador
var delimitador = buff.toString().split('').pop();
if(delimitator === '\n'){
var dados = Buffet.concat(data).toString();
// Resetamos a variável data
// para esperar por mais dados
data = [];
// Enviamos os dados recebidos adiante
processarDados(dados);
}
});
stream.on('end', function(){
console.log('A stream fechou...');
});
stream.on('error', function(err){
throw err;
});
var processarDados = function(dados){
// Chegou dados, bora processar
console.log(dados);
};
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment