.end() isn't always called on previous stream when .stream() is called

[ptarjan]

var TwitterNode = require('../lib').TwitterNode
  , sys         = require('sys')
  , assert      = require('assert');

var twit = new TwitterNode({
  user: 'username', 
  password: 'password',
  follow: [12345, 67890],                  // follow these random users
});

twit
  .addListener('tweet', function(tweet) {
    sys.puts("@" + tweet.user.screen_name + ": " + tweet.text);
  })  

  .addListener('limit', function(limit) {
    sys.puts("LIMIT: " + sys.inspect(limit));
  })  

  .addListener('delete', function(del) {
    sys.puts("DELETE: " + sys.inspect(del));
  })  

  .addListener('end', function(resp) {
    sys.puts("wave goodbye... " + resp.statusCode);
  })  

  .stream();

setInterval(function() {
  var user = Math.floor(Math.random() * 10000000);
  sys.puts('Following '+user);
  twit.follow(user);
  twit.stream();
}, 1000);

Gives:

Following 9177227 Following 8287550 Following 5989591 wave goodbye... 200 Following 2983167 Following 9713078 wave goodbye... 200 Following 9638683 wave goodbye... 200 Following 7539247 wave goodbye... 200 Following 8320555 wave goodbye... 200 Following 4808738 Following 1493951 wave goodbye... 200 Following 7033565 wave goodbye... 200 Following 8097783 wave goodbye... 200 Following 8631714 wave goodbye... 200

The problem with this, is that now I get duplicate "tweet" events called for each existing connection that wasn't closed.

[tim-smart]

Does using the latest HEAD on master fix this for you?

[ptarjan]

I haven't checked, and your fixes conflicted with my local changes. I'll try a merge tonight