user-stream.js

gistfile1.js

response.on('data', function(chunk) {

    data += chunk.toString('utf8');

   //is heartbeat?
    if (data == '\r\n') {
        stream.emit('heartbeat');
        return;
    }

    var index, json;

    while((index = data.indexOf('\r\n')) > -1) {
        json = data.slice(0, index);
        data = data.slice(index + 2);
        if(json.length > 0) {
            try {
                stream.emit('data', JSON.parse(json));
            } catch(e) {
                stream.emit('garbage', data);
            }
        }
    }
});