testing Mongo stream API

mongo_stream.js

var mongo = require('mongodb');
var client = new mongo.Db('test', new mongo.Server('localhost', 27017), {w: 1});

// connect to DB and insert a record
client.open(function(err) {
  client.collection('users', function(err, users) {
    users.insert({email: 'graham@daventry.com'}, function(err) {

      // listen for changes
      var stream = users.find().stream();
      stream.on('data', function(event) {
        
        return console.log({event: event});
        //EXPECTED: should receive insert/update events
        //ACTUAL: receive record after both changes
      });

      // request an update
      users.update(
        {email: 'graham@daventry.com'},
        {$set: { name: 'Graham' }},
        function() {}
      );

    });
  });
});