changed author into userId

added sepatate context for each listening method invocation

Author: arunoda

laika/tests/basic.js

@@ -79,13 +79,13 @@ suite('Basic Communication', function() {
 
  c1.evalSync(function() {
  helloStream.on('evt', function(data) {
- emit('evt', this.author, data);
+ emit('evt', this.userId, data);
  });
  emit('return');
  });
 
- c1.on('evt', function(author, data) {
- assert.ok(author);
+ c1.on('evt', function(userId, data) {
+ assert.ok(userId);
  assert.deepEqual(data, {abc: 10012});
  done();
  });

lib/client.js

@@ -14,9 +14,10 @@ Meteor.Stream = function Stream(name, callback) {
  if(item.type == 'subscriptionId') {
  subscriptionId = item._id;
  } else {
- self.subscriptionId = item.subscriptionId;
- self.author = item.author;
- self._emit.apply(self, item.args); 
+ var context = {};
+ context.subscriptionId = item.subscriptionId;
+ context.userId = item.userId;
+ self._emit.apply(context, item.args); 
  }
  }
  });

lib/server.js

@@ -31,8 +31,8 @@ Meteor.Stream = function Stream(name) {
  filters.push(callback);
  };
 
- function emitToSubscriptions(args, subscriptionId, author) {
- events.emit('item', {args: args, author: author, subscriptionId: subscriptionId});
+ function emitToSubscriptions(args, subscriptionId, userId) {
+ events.emit('item', {args: args, userId: userId, subscriptionId: subscriptionId});
  }
 
  Meteor.publish(streamName, function() {