if subscription is not made, emited events are cached locally and send when connected

Author: arunoda

laika/tests/basic.js

@@ -130,4 +130,27 @@ suite('Basic Communication', function() {
  });
 
  });
+
+ test('client to server: pending events support', function(done, server, client) {
+ server.evalSync(createServerStream, 'hello');
+
+ server.evalSync(function() {
+ helloStream.on('evt2', function(d1, d2) {
+ emit('evt2', d1, d2);
+ });
+ emit('return');
+ });
+
+ server.on('evt2', function(d1, d2) {
+ assert.deepEqual(d1, {abc: 1001});
+ assert.equal(d2, 200);
+ done();
+ });
+
+ client.evalSync(function() {
+ var stream = new Meteor.Stream('hello');
+ stream.emit('evt2', {abc: 1001}, 200);
+ emit('return');
+ });
+ });
 });

lib/client.js

@@ -7,12 +7,20 @@ Meteor.Stream = function Stream(name, callback) {
  var subscription;
  var subscriptionId;
 
+ var connected = false;
+ var pendingEvents = [];
+
  self._emit = self.emit;
 
  collection.find({}).observe({
  "added": function(item) {
  if(item.type == 'subscriptionId') {
  subscriptionId = item._id;
+ connected = true;
+ pendingEvents.forEach(function(args) {
+ self.emit.apply(self, args);
+ });
+ pendingEvents = [];
  } else {
  var context = {};
  context.subscriptionId = item.subscriptionId;
@@ -25,7 +33,11 @@ Meteor.Stream = function Stream(name, callback) {
  subscription = Meteor.subscribe(streamName, callback);
 
  self.emit = function emit() {
- Meteor.call(streamName, subscriptionId, arguments);
+ if(true) {
+ Meteor.call(streamName, subscriptionId, arguments);
+ } else {
+ pendingEvents.push(arguments);
+ }
  };
 
  self.close = function close() {