horrible.js

getMentions: function(options, cb) {

              var process_tweet = require('./processors/tweet')(instance);

              _.defaults(options, {
                include_entities: true,
                include_rts: true
              });

              twitter.getMentions(options, function(err, tweets) {
                if (err) {
                  return cb(err);
                }

                var new_tweets = [];

                function done() {
                  cb(null, new_tweets);
                }

                process_tweet.on('data', function(data) {
                  new_tweets.push(data);
                });

                process_tweet.on('error', function(error) {
                  cb(error);
                });

                tweets.forEach(function(tweet) {
                  process_tweet.write(tweet);
                });
                done();
              });
            }